You can get the assigned partitions via `Consumer#assignment()`. And yes, if `auto.offset.reset` triggers and it set to "latest" the consumer will get the end-offset for each assigned partition and start reading from there.
-Matthias On 10/3/19 12:29 PM, Hrishikesh Mishra 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 >
signature.asc
Description: OpenPGP digital signature
