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 2021/09/24 08:52:44 UTC

[kafka] branch trunk updated (d08e3ad -> b76bcaf)

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 d08e3ad  KAFKA-13315: log layer exception during shutdown that caused an unclean shutdown (#11351)
     add b76bcaf  KAFKA-13102: Topic IDs not propagated to metadata cache quickly enough for Fetch path (#11170)

No new revisions were added by this update.

Summary of changes:
 .../kafka/common/internals/PartitionStates.java    |   5 +
 .../kafka/server/AbstractFetcherManager.scala      |  26 +++++-
 .../scala/kafka/server/AbstractFetcherThread.scala |  52 +++++++----
 .../kafka/server/ReplicaAlterLogDirsThread.scala   |  23 +++--
 .../scala/kafka/server/ReplicaFetcherThread.scala  |   3 +-
 .../main/scala/kafka/server/ReplicaManager.scala   |  52 ++++++++++-
 .../kafka/server/AbstractFetcherManagerTest.scala  |  91 +++++++++++++++++-
 .../kafka/server/AbstractFetcherThreadTest.scala   |  90 +++++++++++-------
 .../AbstractFetcherThreadWithIbp26Test.scala       |   4 +-
 .../server/ReplicaAlterLogDirsThreadTest.scala     |  18 ++--
 .../kafka/server/ReplicaFetcherThreadTest.scala    |  30 +++---
 .../unit/kafka/server/ReplicaManagerTest.scala     | 103 +++++++++++++++++++--
 .../jmh/fetcher/ReplicaFetcherThreadBenchmark.java |   2 +-
 13 files changed, 398 insertions(+), 101 deletions(-)