春季XD卡夫卡源不注册为消费者？

部署来年春天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]

是预期的行为？

来源

2015-11-06 Khoa Nguyen

感谢您使用Spring XD！

就像澄清：Spring XD Kafka源不使用高级消费者（它基于简单的消费者API），因此不在Zookeeper中注册。

希望这有助于马吕斯

来源

2015-11-06 21:26:39

但这也意味着我不能用卡夫卡的监控工具（如卡夫卡经理）来监视主题和他们的消费者。有很好的选择吗？我的目标是监测摄入率和消费率以及是否有任何滞后。 –

我们不使用高层次的消费者，因为它有许多问题和限制 - 在这里几乎可以捕获到：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偏移量管理主题。 –

春季XD卡夫卡源不注册为消费者？

回答

相关问题