This is an automated email from the ASF dual-hosted git repository.
dajac pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 9de16bd KAFKA-10460: ReplicaListValidator format checking is
incomplete (#9326)
add 10364e4 KAFKA-10739; Replace EpochEndOffset with automated protocol
(#9630)
No new revisions were added by this update.
Summary of changes:
.../internals/OffsetsForLeaderEpochClient.java | 12 +-
.../consumer/internals/SubscriptionState.java | 8 +-
.../kafka/common/requests/EpochEndOffset.java | 92 ---------------
.../requests/OffsetsForLeaderEpochRequest.java | 26 ++---
.../requests/OffsetsForLeaderEpochResponse.java | 44 +------
.../message/OffsetForLeaderEpochResponse.json | 4 +-
.../clients/consumer/internals/FetcherTest.java | 126 ++++++++++++++-------
.../internals/OffsetForLeaderEpochClientTest.java | 4 +-
.../consumer/internals/SubscriptionStateTest.java | 27 ++---
.../kafka/common/requests/EpochEndOffsetTest.java | 64 -----------
.../kafka/common/requests/RequestResponseTest.java | 32 +++++-
core/src/main/scala/kafka/cluster/Partition.scala | 26 +++--
core/src/main/scala/kafka/log/Log.scala | 5 +-
.../scala/kafka/server/AbstractFetcherThread.scala | 13 ++-
.../src/main/scala/kafka/server/DelayedFetch.scala | 5 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 35 ++++--
.../kafka/server/ReplicaAlterLogDirsThread.scala | 13 ++-
.../scala/kafka/server/ReplicaFetcherThread.scala | 13 ++-
.../main/scala/kafka/server/ReplicaManager.scala | 57 +++++++---
.../kafka/server/epoch/LeaderEpochFileCache.scala | 2 +-
.../kafka/api/AuthorizerIntegrationTest.scala | 3 +-
.../kafka/server/DelayedFetchTest.scala | 9 +-
.../scala/unit/kafka/cluster/PartitionTest.scala | 11 +-
.../kafka/server/AbstractFetcherThreadTest.scala | 55 ++++++---
.../server/OffsetsForLeaderEpochRequestTest.scala | 10 +-
.../server/ReplicaAlterLogDirsThreadTest.scala | 123 +++++++++++++++++---
.../kafka/server/ReplicaFetcherThreadTest.scala | 76 +++++++++----
.../unit/kafka/server/ReplicaManagerTest.scala | 10 +-
.../server/epoch/LeaderEpochFileCacheTest.scala | 2 +-
.../server/epoch/LeaderEpochIntegrationTest.scala | 15 ++-
.../server/epoch/OffsetsForLeaderEpochTest.scala | 55 +++++++--
.../util/ReplicaFetcherMockBlockingSend.scala | 18 ++-
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 9 +-
33 files changed, 579 insertions(+), 425 deletions(-)
delete mode 100644
clients/src/main/java/org/apache/kafka/common/requests/EpochEndOffset.java
delete mode 100644
clients/src/test/java/org/apache/kafka/common/requests/EpochEndOffsetTest.java
