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/08/26 23:28:56 UTC
[kafka] branch trunk updated (6b24b2e -> 24547b8)

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 6b24b2e  KAFKA-8816: Make offsets immutable to users of RecordCollector.offsets (#7223)
     add 24547b8  KAFKA-8579: Expose RocksDB metrics (#7209)

No new revisions were added by this update.

Summary of changes:
 .../internals/metrics/StreamsMetricsImpl.java      |   2 +-
 .../streams/state/internals/KeyValueSegment.java   |   6 +-
 .../streams/state/internals/KeyValueSegments.java  |  14 +-
 .../internals/RocksDBSegmentedBytesStore.java      |   4 +-
 .../streams/state/internals/RocksDBStore.java      |  50 ++++++-
 .../RocksDBTimestampedSegmentedBytesStore.java     |   4 +-
 .../state/internals/RocksDBTimestampedStore.java   |  11 +-
 .../RocksDbKeyValueBytesStoreSupplier.java         |   4 +-
 .../state/internals/TimestampedSegment.java        |   6 +-
 .../state/internals/TimestampedSegments.java       |  14 +-
 .../state/internals/metrics/RocksDBMetrics.java    |  67 ++++++---
 .../internals/metrics/RocksDBMetricsRecorder.java  | 133 +++++++++++++++++
 .../integration/MetricsIntegrationTest.java        | 163 +++++++++++++++++++--
 .../streams/state/KeyValueStoreTestDriver.java     |   1 +
 .../state/internals/KeyValueSegmentTest.java       |  33 +++--
 .../state/internals/KeyValueSegmentsTest.java      |  11 +-
 .../internals/RocksDBSegmentedBytesStoreTest.java  |   6 +-
 .../streams/state/internals/RocksDBStoreTest.java  |  89 ++++++++++-
 .../RocksDBTimestampedSegmentedBytesStoreTest.java |   6 +-
 .../internals/RocksDBTimestampedStoreTest.java     |   4 +-
 .../state/internals/RocksDBWindowStoreTest.java    |   4 +-
 .../state/internals/SegmentIteratorTest.java       |   7 +-
 .../TimestampedKeyValueStoreBuilderTest.java       |   4 +-
 .../state/internals/TimestampedSegmentTest.java    |  33 +++--
 .../state/internals/TimestampedSegmentsTest.java   |  12 +-
 .../metrics/RocksDBMetricsRecorderTest.java        | 144 ++++++++++++++++++
 .../internals/metrics/RocksDBMetricsTest.java      |   5 +-
 27 files changed, 733 insertions(+), 104 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.java