You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Alec Lee <al...@gmail.com> on 2015/08/19 02:00:09 UTC

error about the storm.kaka.partitionManager

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