KafkaSpout（风暴）不在卡夫卡经理

Question

我使用KafkaSpout ZkHosts配置描述here。

这是SpoutConfig如何初始化：

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

喷口效果很好，它recieving事件发送到卡夫卡。

我该如何设置它，所以Storm会在卡夫卡管理器中作为消费者预备好？

Answer 1

风暴卡夫卡写在不同的位置，并在动物园管理员，而不是做这件事的traiditional卡夫卡方式不同的格式（JSON）的消费信息。您必须在zookeeper中手动查看这些信息。任何卡夫卡监控工具都不适合您的用途。