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
