2016-08-12 139 views
1

我試圖從http客戶端向kafka發送一些指標,從而探索kafka-rest。我的客戶端本身使用並需要端口8082.我試圖將kafka-rest服務的默認端口更改爲8082以外的內容,但它似乎不接受我對融合-fl/etc/kafka-rest/kafka-rest.properties更改Kafka-rest的默認端口

主要我不確定是否知道在此屬性文件中設置的正確密鑰。 我試圖簡單地指定 端口= 8085

和/或

聽衆= 8085

但看代碼:https://github.com/confluentinc/kafka-rest/blob/master/src/main/java/io/confluent/kafkarest/KafkaRestConfig.java好像那裏是沒有辦法覆蓋此端口。它是否正確? 欣賞這方面的任何幫助。

+0

http://docs.confluent.io/3.0.0/kafka-rest/docs/config.html –

回答

0

您必須添加port=8085(或您需要的端口)連接到kafka-rest/kafka-rest.properties