在部署以下spring xd流之后：
“kafka--topics=rm sdrs--outputtype=text/plain--zkconnect=hw1-vapp033:2181 | file--dir=/tmp/myfile--name=all|sdrs”
我希望在Kafka主题“rm sdrs”上看到一个新的消费者，但在zookeeper上什么也看不到：
[zk: localhost:2181(CONNECTED) 14] ls /consumers
[]
[zk: localhost:2181(CONNECTED) 15]这是预期的行为吗？
1条答案
按热度按时间kwvwclae1#
感谢您使用spring xd！
澄清一下：springxdkafka源代码没有使用高级使用者（它基于简单的使用者api），因此没有在zookeeper中注册。
希望这有帮助，马吕斯