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 2020/05/02 00:12:01 UTC
[kafka] branch trunk updated (794648a -> 9453567)

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 794648a  KAFKA-9939; Fix overcounting delayed fetches in request rate metrics (#8586)
     add 9453567  MINOR: Improve Sensor recording efficiency (#8593)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/common/metrics/Sensor.java    | 47 +++++++++++++---------
 .../org/apache/kafka/streams/KafkaStreams.java     |  3 +-
 .../suppress/KTableSuppressProcessorSupplier.java  |  2 +-
 .../internals/AbstractProcessorContext.java        | 11 +++++
 .../internals/InternalProcessorContext.java        | 10 +++++
 .../processor/internals/PartitionGroup.java        |  6 +--
 .../streams/processor/internals/SourceNode.java    |  5 +--
 .../streams/processor/internals/StreamTask.java    | 15 +++----
 .../streams/processor/internals/StreamThread.java  | 14 +++----
 .../kafka/streams/processor/internals/Task.java    |  2 +-
 .../streams/processor/internals/TaskManager.java   |  4 +-
 .../AbstractRocksDBSegmentedBytesStore.java        |  2 +-
 .../state/internals/InMemorySessionStore.java      |  7 +++-
 .../InMemoryTimeOrderedKeyValueBuffer.java         |  9 +++--
 .../state/internals/InMemoryWindowStore.java       |  2 +-
 .../internals/metrics/RocksDBMetricsRecorder.java  | 26 ++++++------
 .../metrics/RocksDBMetricsRecordingTrigger.java    | 10 ++++-
 .../integration/StoreQueryIntegrationTest.java     |  2 +-
 .../KTableSuppressProcessorMetricsTest.java        |  4 ++
 .../processor/internals/PartitionGroupTest.java    | 37 +++++++++--------
 .../processor/internals/RecordQueueTest.java       |  3 +-
 .../processor/internals/StreamTaskTest.java        |  8 ++--
 .../AbstractRocksDBSegmentedBytesStoreTest.java    |  4 ++
 .../internals/AbstractSessionBytesStoreTest.java   |  4 ++
 .../internals/AbstractWindowBytesStoreTest.java    |  4 ++
 .../streams/state/internals/RocksDBStoreTest.java  |  9 +++--
 .../metrics/RocksDBMetricsRecorderTest.java        | 36 ++++++++---------
 .../RocksDBMetricsRecordingTriggerTest.java        |  9 +++--
 .../kafka/test/InternalMockProcessorContext.java   |  3 +-
 .../kafka/test/MockInternalProcessorContext.java   | 11 +++++
 .../java/org/apache/kafka/test/MockSourceNode.java |  4 +-
 .../apache/kafka/streams/TopologyTestDriver.java   |  2 +-
 32 files changed, 197 insertions(+), 118 deletions(-)