You should receive only new messages if the auto.offset.reset is largest. How do you determine that the messages you are receiving are older? Are you checking the lag on your consumer by ConsumerOffsetChecker?
Thanks, Aditya ________________________________________ From: Panda, Samaresh [samaresh.pa...@washpost.com] Sent: Thursday, May 28, 2015 9:31 AM To: users@kafka.apache.org Subject: Java - High Level Consumer I'm following this page https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example and am able to consume messages using four threads. The threads keep receiving messages, which is good. However, I just want to receive only NEW messages and not the old ones. Since the default for auto.offset.reset is 'largest' I expected to receive only new ones, but the messages keep coming including some really old ones. Any other configuration or property change that lets me accomplish this? Thanks
