kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Edward Buck <egb...@hotmail.com>
Subject Getting offset from ConsumerIterator
Date Thu, 05 Apr 2012 21:27:09 GMT

In my consumer, I would like to be able to re-request a message at a specific offset. However,
the ConsumerIterator does not appear to expose the message offset when you call next(). In
order to get an offset for each message, is it necessary to use a SimpleConsumer (the low-level
API), rather than KafkaMessageStream (the high-level API)?Thanks,Ed 		 	   		  
View raw message