kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (bcc0237 -> ad3b843)
Date Tue, 24 Sep 2019 20:29:29 GMT
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 bcc0237  KAFKA-8880: Add overloaded function of Consumer.committed (#7304)
     add ad3b843  KAFKA-8580: Compute RocksDB metrics (#7263)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/KafkaStreams.java     |  72 +++--
 .../processor/internals/GlobalStreamThread.java    |   7 +-
 .../streams/processor/internals/StreamThread.java  |   5 +
 .../internals/metrics/StreamsMetricsImpl.java      |  30 +-
 .../streams/state/internals/KeyValueSegments.java  |   8 +-
 .../streams/state/internals/RocksDBStore.java      |  34 +--
 .../state/internals/TimestampedSegments.java       |   6 -
 .../state/internals/metrics/RocksDBMetrics.java    |   3 +-
 .../internals/metrics/RocksDBMetricsRecorder.java  | 182 ++++++++----
 .../metrics/RocksDBMetricsRecordingTrigger.java    |  56 ++++
 .../integration/MetricsIntegrationTest.java        |   8 +-
 .../internals/GlobalStreamThreadTest.java          |  42 +--
 .../processor/internals/StreamThreadTest.java      |   3 +-
 .../streams/state/internals/RocksDBStoreTest.java  | 142 +++++++---
 .../state/internals/SegmentIteratorTest.java       |   5 +-
 .../metrics/RocksDBMetricsRecorderTest.java        | 315 +++++++++++++++++----
 .../RocksDBMetricsRecordingTriggerTest.java        |  87 ++++++
 .../internals/metrics/RocksDBMetricsTest.java      |  22 +-
 .../kafka/test/InternalMockProcessorContext.java   |   2 +
 .../apache/kafka/streams/TopologyTestDriver.java   |   2 +
 20 files changed, 782 insertions(+), 249 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTrigger.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTriggerTest.java


Mime
View raw message