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                          
           

Reply via email to