在端口8083上,我运行的是Influxdb,我甚至可以在http://localhost:8083上获得图形用户界面
现在来看kafka,这里我指的是https://kafka.apache.org/quickstart的设置。
使用以下命令启动/opt/zookeeper-3.4.10文件夹中的zookeeper:bin/zkServer.sh start
现在启动zookeeper,在/opt/ kafka _2.11-1.1.0文件夹下启动kafka:
bin/kafka-server-start.sh config/server.properties
创建一个名为test的topic,其中只有一个副本,只有一个分区:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
Topic已创建,可以使用以下命令签入:
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
我甚至更改了/opt/kafka_2.11-1.1.0/config/connect-distributed.properties中的rest.port=8084
,这样它就不会与已经在8083上的influxdb发生冲突。尽管如此,我还是得到了截图中显示的相同的Address already in use
,Kafka connect has stopped
。
发布于 2018-06-07 18:44:03
由于您是在独立模式下使用Kafka Connect,因此您需要在config/connect-standalone.properties
中更改REST端口:
rest.port=18083
要了解有关单机版与分布式版的更多信息,您可以使用read the doc here。
发布于 2018-11-14 04:20:28
Kafka独立模式,默认使用Port 8084
作为Rest API post。由于这个原因,如果其他人已经在使用该端口,进程将抛出一个BindException
。
要更改上面使用的端口,请导航到Kafka Root目录中的config/connect-standalone.properties
文件。
添加以下键值属性以更改用于Rest API打开的端口。(默认情况下,Kafka应该将其包含在属性文件中,否则许多开发人员会发疯,试图找到独立模式中使用的端口映射)。根据您的需要添加不同的端口。
rest.port=11133
发布于 2021-10-12 11:09:43
Kafka 3.0.0
由于Kafka Connect旨在作为服务运行,因此它还提供了一个REST API来管理连接器。可以使用listeners配置选项配置REST API服务器。此字段应包含以下格式的侦听器列表: protocol://host:port,protocol 2://host2:port2。目前支持的协议有http和https。例如: HTTP http://localhost:8080,https://localhost:8443默认情况下,如果未指定侦听器,则REST服务器使用listeners=协议在端口8083上运行。
https://stackoverflow.com/questions/50698358
复制相似问题