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 >
