If I get your question right, your concern isn't about auto.offset.reset - it's the partition assignment.
consumer group represents parallelism. It's well-documented in Kafka official docs. Each consumer (in a consumer group) gets fare share of job (i.e. # partitions for a topic subscription). Due to rebalance or disgraceful departure of consumers from a group, the partitions get reassigned to live consumers. In that case you will end up having some difference in workload per consumer in a group. Once again, this is well-explained in the official doc. Thanks, On Thu, 3 Oct 2019 at 20:30, Hrishikesh Mishra <sd.hri...@gmail.com> wrote: > Hi, > > I want to understand how does *auto.offset.reset = latest *work. When > consumer first call poll() method, will it assign the current offsets to > consumer for all partition (when single consumer is up in a consumer > group)? How do I know all partitions are assigned to a consumer? > > > Regards > Hrishikesh >
