首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >如何更改"kafka connect“组件端口?

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

Stack Overflow用户
提问于 2018-06-05 18:56:08
回答 4查看 10.1K关注 0票数 4

在端口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 useKafka connect has stopped

EN

回答 4

Stack Overflow用户

回答已采纳

发布于 2018-06-07 18:44:03

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

代码语言:javascript
复制
rest.port=18083

要了解有关单机版与分布式版的更多信息,您可以使用read the doc here

票数 7
EN

Stack Overflow用户

发布于 2018-11-14 04:20:28

Kafka独立模式,默认使用Port 8084作为Rest API post。由于这个原因,如果其他人已经在使用该端口,进程将抛出一个BindException

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

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

代码语言:javascript
复制
rest.port=11133
票数 0
EN

Stack Overflow用户

发布于 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://kafka.apache.org/documentation/#connect_rest

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/50698358

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档