部署以下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 回答
感谢您使用Spring XD!
正如澄清一样:Spring XD Kafka源不使用高级消费者(它基于简单的消费者API),因此没有在Zookeeper中注册 .
希望这有帮助,马吕斯