See : https://github.com/apache/storm more specifically: https://github.com/apache/storm/blob/master/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java Inside, the class, KafkaMessageId is defined. You probably want to check out the code for the Storm version you are using. See the branch's tags.
From: neo21 zerro <[email protected]<mailto:[email protected]>> Reply-To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>>, neo21 zerro <[email protected]<mailto:[email protected]>> Date: 2015,Thursday, May 7 at 03:42 To: "[email protected]<mailto:[email protected]>" <[email protected]<mailto:[email protected]>> Subject: KafkaSpout emit partition id and offset in tuple Hey guys, I need to access the partition id and offset in a bolt. I see that you emit that via the message ID. Is this information accessible in bolts? Any ideas´? Many thanks!
