Hey Chia,

this is mentioned in the KIP, albeit well hidden: "Where, for simplicity,
we can assume the assignment epoch of a partition that is not assigned to
that member to be Integer.maxValue.". Although I realize now that this
explanation suffers from an off-by-one error, so let me put it this way:

You cannot commit partitions that are not assigned to you.

Hope that clarifies it.

Cheers
Lucas

Chia-Ping Tsai <[email protected]> schrieb am Sa., 14. Feb. 2026, 10:57:

> hi Lucas
>
> thanks for this KIP. I have a small question.
>
> What happens if the request brings a partition which is not hosted by the
> member id? IIRC, we didn't check it before
>
> Best,
> Chia-Ping
>
> On 2025/12/18 19:59:56 Lucas Brutschy via dev wrote:
> > Hi all,
> >
> > I posted a new KIP to add assignment epochs to KIP-848-style consumer
> > groups. The idea is to avoid failing offset commits in the new
> > consumer protocol by relaxing the member epoch validation slightly.
> >
> > Please take a look and let me know what you think:
> >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1251%3A+Assignment+epochs+for+consumer+groups
> >
> > Cheers,
> > Lucas
> >
>

Reply via email to