KafkaSpout（風暴）不在卡夫卡經理

Question

我使用KafkaSpout ZkHosts配置描述here。

這是SpoutConfig如何初始化：

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

噴口效果很好，它recieving事件發送到卡夫卡。

我該如何設置它，所以Storm會在卡夫卡管理器中作爲消費者預備好？

Answer 1

風暴卡夫卡寫在不同的位置，並在動物園管理員，而不是做這件事的traiditional卡夫卡方式不同的格式（JSON）的消費信息。您必須在zookeeper中手動查看這些信息。任何卡夫卡監控工具都不適合您的用途。