首页 文章

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

提问于
浏览 次
1

在端口8083上我运行Influxdb我甚至在http://localhost:8083上获取GUI

现在来kafka，我在这里引用设置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

在这里，一切都很好，并调整 .

现在我需要使用“ 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

enter image description here

enter image description here

我甚至更改了/opt/kafka_2.11-1.1.0/config/connect-distributed.properties中的 rest.port=8084 ，因为它不会与已经在8083上的Influxdb发生冲突 . 我仍然得到相同的 Address already in use ， Kafka connect has stopped as屏幕截图中显示 .

apache-kafka-connect

3 回答

  • -3

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

    rest.port=18083

    要了解有关Standalone vs Distributed的更多信息，您可以read the doc here .

    回复于
  • 3

    默认情况下，Kafka Standalone模式使用 Port 8084 作为Rest API帖子 . 由于这个原因，如果其他人已经在使用该端口，则抛出一个 BindException 进程 .

    要更改上面使用的端口，请导航到Kafka Root目录中的 config/connect-standalone.properties 文件 .

    添加以下键值属性以更改用于Rest API打开的端口 . （默认情况下，Kafka应该将其包含在属性文件中，否则许多开发人员会试图找到独立模式中使用的端口映射） . 根据需要放置不同的端口 .

    rest.port=11133
    回复于
  • 0

    更改config / server.properties中的 port 定义：

    # The port the socket server listens on
port=9092
    回复于

相关问题