storm-kafka spout獲取資料的異常解決辦法
阿新 • • 發佈：2019-01-23
20391 [Thread-8-kfkaSpout] WARN storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140885176]; retrying with default start offset time from configuration. configured start offset time: [-2] offset: [5532601] 21680 [Thread-8-kfkaSpout] WARN storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140889217]; retrying with default start offset time from configuration. configured start offset time: [-2] offset: [5532613] 22749 [Thread-8-kfkaSpout] WARN storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140890119]; retrying with default start offset time from configuration. configured start offset time: [-2] offset: [5532311] 23771 [Thread-8-kfkaSpout] WARN storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140884842]; retrying with default start offset time from configuration. configured start offset time: [-2] offset: [5532819] 24681 [Thread-8-kfkaSpout] WARN storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140772081]; retrying with default start offset time from configuration. configured start offset time: [-2] offset: [5532980] 25611 [Thread-8-kfkaSpout] WARN storm.kafka.KafkaUtils - Got fetch request with offset out of range: [140885176]; retrying with default start offset
多個topic不能共用一個zookeeper根目錄data
SpoutConfig spoutConfig = new SpoutConfig(zkHosts, topic, "/data","logProcess");