You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2020/08/13 19:41:45 UTC
[kafka] branch trunk updated (3a189ad -> 5645d90)
This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 3a189ad KAFKA-10386; Fix flexible version support for `records` type (#9163)
add 5645d90 KAFKA-9924: Prepare RocksDB and metrics for RocksDB properties recording (#9098)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 15 +-
.../internals/metrics/StreamsMetricsImpl.java | 12 +-
... BlockBasedTableConfigWithAccessibleCache.java} | 18 +-
.../streams/state/internals/RocksDBStore.java | 45 +++--
.../internals/metrics/RocksDBMetricsRecorder.java | 160 ++++++++++------
...KStreamSessionWindowAggregateProcessorTest.java | 3 +-
.../processor/internals/ActiveTaskCreatorTest.java | 2 +-
.../internals/GlobalStreamThreadTest.java | 8 +-
.../processor/internals/MockStreamsMetrics.java | 3 +-
.../processor/internals/ProcessorNodeTest.java | 6 +-
.../processor/internals/SourceNodeTest.java | 4 +-
.../processor/internals/StandbyTaskTest.java | 2 +-
.../processor/internals/StreamTaskTest.java | 2 +-
.../processor/internals/StreamThreadTest.java | 48 +++--
.../internals/metrics/StreamsMetricsImplTest.java | 50 ++---
...ockBasedTableConfigWithAccessibleCacheTest.java | 54 ++++++
.../internals/GlobalStateStoreProviderTest.java | 5 +-
.../state/internals/KeyValueSegmentTest.java | 14 ++
.../state/internals/MeteredKeyValueStoreTest.java | 8 +-
.../state/internals/MeteredSessionStoreTest.java | 7 +-
.../MeteredTimestampedKeyValueStoreTest.java | 6 +-
.../MeteredTimestampedWindowStoreTest.java | 2 +-
.../state/internals/MeteredWindowStoreTest.java | 3 +-
.../streams/state/internals/RocksDBStoreTest.java | 112 +++++++-----
.../state/internals/TimestampedSegmentTest.java | 14 ++
.../metrics/RocksDBMetricsRecorderTest.java | 202 ++++++++++++++++-----
.../kafka/test/InternalMockProcessorContext.java | 26 ++-
.../apache/kafka/streams/TopologyTestDriver.java | 5 +-
.../streams/processor/MockProcessorContext.java | 4 +-
29 files changed, 590 insertions(+), 250 deletions(-)
copy streams/src/main/java/org/apache/kafka/streams/state/internals/{RocksDBTimestampedWindowStore.java => BlockBasedTableConfigWithAccessibleCache.java} (67%)
create mode 100644 streams/src/test/java/org/apache/kafka/streams/state/internals/BlockBasedTableConfigWithAccessibleCacheTest.java