2015-11-06 112 views
1

部署來年春天XD流後:春季XD卡夫卡源不註冊爲消費者?

「海邊的卡夫卡--topics = RM-特別提款權--outputType = text/plain的--zkconnect = HW1-vapp033:2181 |文件--dir =/tmp目錄/文件MyFile - -name = all_sdrs」

我希望看到卡夫卡的主題新的消費者‘RM-特別提款權’,但看到動物園管理員什麼:

[zk: localhost:2181(CONNECTED) 14] ls /consumers 
[] 
[zk: localhost:2181(CONNECTED) 15] 

是預期的行爲?

回答

2

感謝您使用Spring XD!

就像澄清:Spring XD Kafka源不使用高級消費者(它基於簡單的消費者API),因此不在Zookeeper中註冊。

希望這有助於 馬呂斯

+0

但這也意味着我不能用卡夫卡的監控工具(如卡夫卡經理)來監視主題和他們的消費者。有很好的選擇嗎?我的目標是監測攝入率和消費率以及是否有任何滯後。 –

+2

我們不使用高層次的消費者,因爲它有許多問題和限制 - 在這裏幾乎可以捕獲到:https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Client+Re-Design。話雖如此,將於11月底發佈的Spring XD 1.3版將通過原生Kafka主題支持來支持偏移管理。如果'kafka-manager'完全依賴於監控高級消費者,我會建議嘗試https://github.com/quantifind/KafkaOffsetMonitor,它支持監控0.8.2 kafka偏移量管理主題。 –