dengziming commented on PR #12274: URL: https://github.com/apache/kafka/pull/12274#issuecomment-1182937575
> I see. This would not work for co-located Kafka servers, right? @jsancio you are right, this is why I'm trying to find a simpler solution, for example, letting the broker send the local LEO instead of the last applied offset, this is the logic how we expand topic-partition ISR, the problem is that the broker may haven't applied the LEO as you mentioned. maybe we should allow the lastAppliedOffset to be behind by A records (or time) to unfence the broker. -- 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
