Thank you for the reply. I thought that was what I found, but unfortunately wasn't.
The previous messages still be consumed while the consumer has been re-executed with a few shutdown time... 2016-07-12 9:54 GMT+09:00 Snehal Nagmote <nagmote.sne...@gmail.com>: > Hello *,* > > If I understand your question correctly , what you are looking for is a > setting in consumer which will only read latest messages . > > auto.offset.reset = latest > > This way , when you start new consumer group , it will always start reading > from the recent offset, > > > Thanks, > Snehal > > > > > > > > On 11 July 2016 at 17:38, BYEONG-GI KIM <bg...@bluedigm.com> wrote: > > > Hello. > > > > Generally, a Kafka Consumer consumes stored messages from Kafka Broker(s) > > when the Consumer has been executed. > > > > I, however, want to create a function that only consumes incoming > messages > > after executing, instead of consuming the previously stored messages as I > > mentioned above, for real-time application. > > > > Is it doable? If yes, how could it be implemented? Any example code or > > reference would really be helpful for me. > > > > Thanks in advance! > > > > Best regards > > > > KIM > > >
