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

2024-02-01

在端口 8083 上我正在运行 Influxdb,我什至可以打开 GUIhttp://本地主机:8083 http://localhost:8083

现在来到kafka,这里我指的是按照https://kafka.apache.org/quickstart https://kafka.apache.org/quickstart

通过以下命令启动文件夹 /opt/zookeeper-3.4.10 中的 Zookeeeper: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

到目前为止,一切都很好并且经过调整。

现在我需要使用“卡夫卡连接“导入/导出数据的组件。 所以我创建一个种子数据:echo -e "foo\nbar" > test.txt

现在使用连接器配置“卡夫卡连接“ 上班 :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如屏幕截图所示。


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

rest.port=18083

要了解有关独立与分布式的更多信息,您可以在这里阅读文档 https://docs.confluent.io/current/connect/userguide.html#standalone-vs-distributed.

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何更改“kafka connect”组件端口? 的相关文章

随机推荐