You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2019/10/16 16:50:22 UTC
[kafka] branch trunk updated (0725035 -> 8966d06)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 0725035 KAFKA-9032: Bypass serdes for tombstones (#7518)
add 8966d06 KAFKA-9039: Optimize ReplicaFetcher fetch path (#7443)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control-jmh-benchmarks.xml | 2 +
.../apache/kafka/clients/FetchSessionHandler.java | 44 ++-
.../kafka/common/internals/PartitionStates.java | 2 +-
.../scala/kafka/server/AbstractFetcherThread.scala | 117 ++++----
.../kafka/server/ReplicaAlterLogDirsThread.scala | 19 +-
.../scala/kafka/server/ReplicaFetcherThread.scala | 30 +-
.../kafka/server/AbstractFetcherManagerTest.scala | 2 +-
.../kafka/server/AbstractFetcherThreadTest.scala | 15 +-
.../server/ReplicaAlterLogDirsThreadTest.scala | 27 +-
gradle/spotbugs-exclude.xml | 2 +
.../jmh/fetcher/ReplicaFetcherThreadBenchmark.java | 312 +++++++++++++++++++++
.../jmh/fetchsession/FetchSessionBenchmark.java | 119 ++++++++
12 files changed, 579 insertions(+), 112 deletions(-)
create mode 100644 jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java
create mode 100644 jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetchsession/FetchSessionBenchmark.java