very helpful, thanks!
On Monday, May 11, 2015 5:00 PM, Jeff Maass <[email protected]> wrote:
See :https://github.com/apache/stormmore
specifically:https://github.com/apache/storm/blob/master/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.javaInside,
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]>
Reply-To: "[email protected]" <[email protected]>, neo21 zerro
<[email protected]>
Date: 2015,Thursday, May 7 at 03:42
To: "[email protected]" <[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!
