我试图从一个http客户机向kafka发送一些度量,从而探索kafka rest。我的客户机本身使用并需要端口8082。我正在尝试将kafka rest服务的默认端口更改为8082以外的端口,但它似乎不接受我对confluent-1.0/etc/kafka-rest/kafka-rest.properties所做的任何更改
主要是我不知道我是否知道在这个属性文件中设置正确的键。我尝试简单地指定port=8085
和/或
听众=8085
但是看看code:https://github.com/confluentinc/kafka-rest/blob/master/src/main/java/io/confluent/kafkarest/kafkarestconfig.java似乎无法覆盖此端口。是这样吗?感谢您在这方面的帮助。
2条答案
按热度按时间juud5qan1#
添加
listeners=“http://0.0.0.0:8085“
在/etc/kafka-rest/kafka-rest.properties
.port
属性已弃用。文件-https://docs.confluent.io/5.2.0/kafka-rest/docs/config.html
dgtucam12#
你必须加上
port=8085
(或您想要的端口)到您的kafka-rest/kafka-rest.properties