kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [kafka] branch trunk updated (9de16bd -> 10364e4)
Date Thu, 03 Dec 2020 17:51:48 GMT
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


Mime
View raw message