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
Passing builds:
Unit/integration tests https://builds.apache.org/job/kafka-2.3-jdk8/122/
System tests https://jenkins.confluent.io/job/system-test-kafka/job/2.3/142/
On Fri, Oct 4, 2019 at 9:52 PM David Arthur wrote:
> Hello all, we identified a few bugs and a dependency update we wanted to
>
Hi Navneeth,
I think your plan to implement branching with the Processor API sounds
reasonable, but I'm
wondering why not just use the DSL branch operator and connect some
transformers? That
will let you mix the DSL and PAPI so you don't have to re-implement
anything that is already
in the DSL.
