KafkaSpout (Storm) Не отображается в Kafka Manager

Question

Я использую KafkaSpout с конфигурацией ZkHosts, как описано here.

Это как SpoutConfig инициализируется:

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

носик хорошо работает, он ПОЛУЧАТЬ события направляются к Кафке.

Как я могу установить его, поэтому Storm будет распространяться как потребитель в Kafka Manager?

Answer 1

Storm-Кафка пишет свою потребительскую информацию в другом месте и другом формате (JSON) в, а не зоопарка traiditional Кафка способ сделать это. Вы должны видеть такую ​​информацию вручную в zookeeper. Любой инструмент мониторинга кафки не будет работать для вашей цели.