我将kafkaspout与zkhosts配置一起使用，如下所述。
这是如何初始化spoutconfig的：
SpoutConfig kafkaConfig = new SpoutConfig(kafkaBrokerHosts, kafkaTopic,
"/consumers" , topologyName);喷口工作得很好，它正在接收发送给Kafka的事件。
我如何设置它，使风暴将作为一个消费者在Kafka经理aprear？
我将kafkaspout与zkhosts配置一起使用，如下所述。
这是如何初始化spoutconfig的：
SpoutConfig kafkaConfig = new SpoutConfig(kafkaBrokerHosts, kafkaTopic,
"/consumers" , topologyName);喷口工作得很好，它正在接收发送给Kafka的事件。
我如何设置它，使风暴将作为一个消费者在Kafka经理aprear？
1条答案
按热度按时间wribegjk1#
storm kafka在zookeeper中以不同的位置和不同的格式（json）写入消费者信息，而不是传统的kafka方式。您必须在zookeeper中手动查看这些信息。任何Kafka监控工具都不适合你。