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 (e16859d -> cde6d18)
Date Wed, 12 Feb 2020 01:31:41 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 e16859d  KAFKA-9390: Make serde pseudo-topics unique (#8054)
     add cde6d18  KAFKA-9355: Fix bug that removed RocksDB metrics after failure in EOS (#7996)

No new revisions were added by this update.

Summary of changes:
 .../streams/state/internals/KeyValueSegments.java  |   8 +-
 .../streams/state/internals/RocksDBStore.java      |   3 +-
 .../state/internals/TimestampedSegments.java       |   6 +
 .../internals/metrics/RocksDBMetricsRecorder.java  |  31 ++-
 .../integration/MetricsIntegrationTest.java        |  58 ----
 .../integration/RocksDBMetricsIntegrationTest.java | 295 +++++++++++++++++++++
 .../state/internals/KeyValueSegmentsTest.java      |   2 +
 .../streams/state/internals/RocksDBStoreTest.java  |   8 +-
 .../state/internals/SegmentIteratorTest.java       |   4 +-
 .../state/internals/TimestampedSegmentsTest.java   |   2 +
 .../metrics/RocksDBMetricsRecorderTest.java        | 145 ++++++----
 11 files changed, 426 insertions(+), 136 deletions(-)
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/RocksDBMetricsIntegrationTest.java


Mime
View raw message