Hello, All
I am consuming roughly 1000000 records from kafka by using KafkaSpoutTopology,
I create the topic with no partition in Kafka, when I consume it, it getting
such error:
162306 [Thread-21-words] INFO storm.kafka.PartitionManager - Skipping failed
tuple at offset=208822 because it's more than maxOffsetBehind=100000 behind
_emittedToOffset=737773
162306 [Thread-21-words] INFO storm.kafka.PartitionManager - Skipping failed
tuple at offset=265580 because it's more than maxOffsetBehind=100000 behind
_emittedToOffset=737773
162305 [Thread-9-print] INFO storm.ingress.KafkaSpoutTopology - source:
words:4, stream: default, id: {-1055532377332201938=454769426954093354},
[{"sensor_id": "febc0080", "period": 60, "powermon_num": 7638059, "current":
"0.2880", "time_stamp": "2013-03-20 13:25:00-07:00", "id":
"b5a85b14-9495-4d93-8a4d-066f09d564df", "date_uploaded": "2013-03-26
15:21:14.173000-07:00"}]
It seems to be the error about the Offset config, where about to re-config it?
thanks
AL
