This is an automated email from the ASF dual-hosted git repository.
jgus pushed a change to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 5ccf943 Cherry-pick KAFKA-7278; replaceSegments() should not call
asyncDeleteSegment() for segments which have been removed from segments list
new a700895 KAFKA-7164; Follower should truncate after every missed
leader epoch change (#5436)
new 74d5c91 KAFKA-7128; Follower has to catch up to offset within current
leader epoch to join ISR (#5557)
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
core/src/main/scala/kafka/cluster/Partition.scala | 36 +++-
.../scala/unit/kafka/cluster/PartitionTest.scala | 112 +++++++++-
.../unit/kafka/server/ReplicaManagerTest.scala | 229 ++++++++++++++++++++-
3 files changed, 361 insertions(+), 16 deletions(-)
