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 19:11:04 UTC
storm.kafka.partitionManager error

Hello, All

I am getting such error when I am consuming the data from Kafka

142856 [Thread-21-words] INFO  storm.kafka.PartitionManager - Skipping failed tuple at offset=457880 because it's more than maxOffsetBehind=100000 behind _emittedToOffset=816657
142857 [Thread-21-words] INFO  storm.kafka.PartitionManager - Skipping failed tuple at offset=416694 because it's more than maxOffsetBehind=100000 behind _emittedToOffset=816657
142857 [Thread-9-print] INFO  storm.ingress.KafkaSpoutTopology - source: words:4, stream: default, id: {7132228343766292022=-4296213912653573477}, [{"sensor_id": "febc0062", "period": 60, "powermon_num": 7853114, "current": "3.1380", "time_stamp": "2013-03-10 20:39:00-07:00", "id": "49cbab27-f2a9-40e4-93c7-f0f691149956", "date_uploaded": "2013-03-26 19:57:44.813000-07:00"}]
142857 [Thread-21-words] INFO  storm.kafka.PartitionManager - Skipping failed tuple at offset=398327 because it's more than maxOffsetBehind=100000 behind _emittedToOffset=816657
142857 [Thread-21-words] INFO  storm.kafka.PartitionManager - Skipping failed tuple at offset=508874 because it's more than maxOffsetBehind=100000 behind _emittedToOffset=816657
142857 [Thread-21-words] INFO  storm.kafka.PartitionManager - Skipping failed tuple at offset=583919 because it's more than maxOffsetBehind=100000 behind _emittedToOffset=816657
142857 [Thread-21-words] INFO  storm.kafka.PartitionManager - Skipping failed tuple at offset=370661 because it's more than maxOffsetBehind=100000 behind _emittedToOffset=816657
142857 [Thread-21-words] INFO  storm.kafka.PartitionManager - Skipping failed tuple at offset=608482 because it's more than maxOffsetBehind=100000 behind _emittedToOffset=816657
142857 [Thread-21-words] INFO  storm.kafka.PartitionManager - Skipping failed tuple at offset=407853 because it's more than maxOffsetBehind=100000 behind _emittedToOffset=816657
142857 [Thread-9-print] INFO  storm.ingress.KafkaSpoutTopology - source: words:4, stream: default, id: {-421350747754706132=8547282746507421649}, [{"sensor_id": "febc0062", "period": 60, "powermon_num": 7853129, "current": "5.5370", "time_stamp": "2013-03-10 20:54:00-07:00", "id": "d2659eb3-2d0d-4633-9aa0-9e5a8a9a7912", "date_uploaded": "2013-03-26 19:57:44.813000-07:00"}]


Any idea what is problem?

thanks

AL