dajac commented on PR #19631: URL: https://github.com/apache/kafka/pull/19631#issuecomment-2867059819
> > Do we skip events because we somehow commit offsets of unprocessed records due to the race condition? > > Hi @dajac, this is precisely the side effect of this race condition. Understood. I don't fully grasp the sequence of events leading to it. The description of the pull request suggests that the commit fails before the offsets are sent to the group coordinator. Intuitively, I would think that it should re-process records instead of skipping records when the partition is re-assigned. I would like to better understand it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
