You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by da...@apache.org on 2020/12/17 16:42:16 UTC

[kafka] branch trunk updated (4089c36 -> 02a30a5)

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 4089c36  KAFKA-10861; Fix race condition in flaky test `testFencingOnSendOffsets` (#9762)
     add 02a30a5  KAFKA-10740; Replace OffsetsForLeaderEpochRequest.PartitionData with automated protocol (#9689)

No new revisions were added by this update.

Summary of changes:
 .../requests/OffsetsForLeaderEpochRequest.java     | 42 ++--------------------
 .../apache/kafka/common/requests/RequestUtils.java |  2 +-
 .../requests/OffsetsForLeaderEpochRequestTest.java |  4 +--
 .../kafka/common/requests/RequestResponseTest.java | 13 +------
 .../scala/kafka/server/AbstractFetcherThread.scala | 32 +++++++++--------
 .../kafka/server/ReplicaAlterLogDirsThread.scala   |  3 +-
 .../scala/kafka/server/ReplicaFetcherThread.scala  | 17 +++++++--
 .../kafka/server/AbstractFetcherThreadTest.scala   | 30 ++++++++++++----
 .../server/OffsetsForLeaderEpochRequestTest.scala  | 26 ++++++++++++--
 .../server/ReplicaAlterLogDirsThreadTest.scala     | 19 +++++++---
 .../kafka/server/ReplicaFetcherThreadTest.scala    | 11 ++++--
 .../server/epoch/LeaderEpochIntegrationTest.scala  | 20 ++++++++---
 .../jmh/fetcher/ReplicaFetcherThreadBenchmark.java |  4 +--
 13 files changed, 125 insertions(+), 98 deletions(-)