首页 文章

Spring XD Kafka源没有注册为消费者?

提问于
浏览
1

部署以下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 回答

  • 2

    感谢您使用Spring XD!

    正如澄清一样:Spring XD Kafka源不使用高级消费者(它基于简单的消费者API),因此没有在Zookeeper中注册 .

    希望这有帮助,马吕斯

相关问题