Re: Using SimpleConsumer to get messages from offset until now

Thank you! I will definitely look into that example. 2015-06-03 4:27 GMT+02:00 luo.fucong : > I think the SimpleConsumer Example( > https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example > < > https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example>)

Re: Using SimpleConsumer to get messages from offset until now

I think the SimpleConsumer Example(https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example ) in the wiki is a very good starting point. You can pass in the offset to the FetchRequest. And you

Using SimpleConsumer to get messages from offset until now

Hello, I'm trying to create a custom consumer that given a offset returns all messages until now. After this is done, the consumer is not needed anymore, hence, the consumer does not have to continue consuming messages that are being produced. The Kafka cluster exists of one broker and we only us