>
> Best,
>
> From: Sophie Blee-Goldman
> Sent: Tuesday, March 16, 2021 5:58 AM
> To: users@kafka.apache.org
> Subject: Re: Slightly Modified Sticky Assignor.
>
> Hey Mazen,
>
> The easiest way to approach this is probably to pass in a
Great, thanks so much for the detailed answer.
Best,
From: Sophie Blee-Goldman
Sent: Tuesday, March 16, 2021 5:58 AM
To: users@kafka.apache.org
Subject: Re: Slightly Modified Sticky Assignor.
Hey Mazen,
The easiest way to approach this is probably to pass in a
Hey Mazen,
The easiest way to approach this is probably to pass in a reference to the
associated Consumer and
then just call one of the *Consumer#committed *methods which return the
OffsetAndMetadata.
But I'm guessing your underling question may be about how to get that
reference to the Consumer
Hi all,
I am implementing a custom partition assignor slightly different than the
sticky assignor assignor. As known, in the sticky assignor each consumer sends
the set of owned partitions as part of its subscription message. This happens
in the subscriptionUserData by calling the serializeTop
