Storm消費Kafka提交集羣運行

1.創建拓撲,配置KafkaSpout、Bolt KafkaTopologyBasic.java: package org.mort.storm.kafka; import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.consumer.ConsumerRecord; impor
相關文章
相關標籤/搜索