如何更改“kafka connect”组件端口？

Question

在端口 8083 上，我正在运行 Influxdb，我什至在http://localhost:8083上获得了 GUI

现在来到 kafka，这里我指的是按照https://kafka.apache.org/quickstart 进行的设置

通过以下命令启动文件夹 /opt/zookeeper-3.4.10 中的动物园管理员： bin/zkServer.sh start

所以zookeeper现在开始在/opt/kafka_2.11-1.1.0文件夹下启动kafka：
bin/kafka-server-start.sh config/server.properties

创建一个名为“test”的主题，只有一个分区和一个副本：
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

主题已创建并可使用命令签入：
bin/kafka-topics.sh --list --zookeeper localhost:2181

Uptill 到这里一切都很好和调整。

现在我需要使用“ Kafka connect ”组件来导入/导出数据。所以我正在创建一个种子数据：echo -e "foo\nbar" > test.txt

现在使用“ kafka connect ”的连接器配置来工作： bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties

运行上述命令后，我得到： Address already in use

Kafka connect has stopped

我什至rest.port=8084在 /opt/kafka_2.11-1.1.0/config/connect-distributed.properties 中更改了它，以免与 8083 上的 influxdb 发生冲突。我仍然得到相同的结果Address already in use， Kafka connect has stopped如屏幕截图所示.

Answer 1

由于您在独立模式下使用 Kafka Connect，您需要更改 REST 端口config/connect-standalone.properties：

rest.port=18083

要了解有关独立与分布式的更多信息，您可以在此处阅读文档。