KafkaSpout (Storm) 不出现在 Kafka Manager 中

Question

我正在使用带有 ZkHosts 配置的 KafkaSpout，如 here 所述。

SpoutConfig 是这样初始化的：

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

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

我该如何设置，Storm 将作为消费者出现在 Kafka Manager 中？

Answer 1

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