Kafka Spout (Storm) 没有出现在 Kafka Manager 中

Question

我正在使用 KafkaSpout 和 ZkHosts 配置，如 here 所述。

SpoutConfig 是这样初始化的：

 SpoutConfig kafkaConfig = new SpoutConfig(kafkaBrokerHosts, kafkaTopic,
            "/consumers" , topologyName);

Spout 运行良好，它正在接收发送到 Kafka 的事件。

我如何设置它，让 Storm 在 Kafka Manager 中成为消费者？

Answer 1

Storm-kafka 在 zookeeper 中以不同的位置和不同的格式 (JSON) 写入其消费者信息，而不是传统的 kafka 方式。您必须在 zookeeper 中手动查看此类信息。任何 kafka 监控工具都无法满足您的目的。