[
https://issues.apache.org/jira/browse/KAFKA-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16619850#comment-16619850
]
ASF GitHub Bot commented on KAFKA-7395:
---------------------------------------
hachikuji opened a new pull request #5661: KAFKA-7395; Add fencing to
replication protocol (KIP-320)
URL: https://github.com/apache/kafka/pull/5661
This patch contains the broker-side support for the fencing improvements
from KIP-320. This includes the leader epoch validation in the ListOffsets,
OffsetsForLeaderEpoch, and Fetch APIs as well as the changes needed in the
fetcher threads to maintain and use the current leader epoch. The client
changes from KIP-320 will be left for a follow-up, but the new error codes have
been added to the error handling inside `Fetcher`.
One notable change worth mentioning is that we now require the read lock in
`Partition` in order to read from the log or to query offsets. This is
necessary to ensure the safety of the leader epoch validation. Additionally, we
forward all leader epoch changes to the replica fetcher thread and go through
the truncation phase. This is needed to ensure the fetcher always has the
latest epoch and to guarantee that we cannot miss needed truncation if we
missed an epoch change.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Add fencing to replication protocol (KIP-320)
> ---------------------------------------------
>
> Key: KAFKA-7395
> URL: https://issues.apache.org/jira/browse/KAFKA-7395
> Project: Kafka
> Issue Type: Improvement
> Reporter: Jason Gustafson
> Assignee: Jason Gustafson
> Priority: Major
>
> This patch implements the broker-side changes to support fencing improvements
> from KIP-320:
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-320%3A+Allow+fetchers+to+detect+and+handle+log+truncation
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
