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 3b05dc6 MINOR: just remove leader on trunk like we did on 2.3 (#7447)
add 52007e8 KAFKA-8934: Introduce instance-level metrics for streams
applications (#7416)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 22 +-
.../streams/internals/metrics/ClientMetrics.java | 116 +++++++++
.../kstream/internals/KStreamAggregate.java | 2 +-
.../kstream/internals/KStreamKStreamJoin.java | 2 +-
.../internals/KStreamKTableJoinProcessor.java | 2 +-
.../streams/kstream/internals/KStreamReduce.java | 2 +-
.../internals/KStreamSessionWindowAggregate.java | 2 +-
.../kstream/internals/KStreamWindowAggregate.java | 2 +-
.../kstream/internals/KTableKTableInnerJoin.java | 2 +-
.../kstream/internals/KTableKTableLeftJoin.java | 2 +-
.../kstream/internals/KTableKTableOuterJoin.java | 2 +-
.../kstream/internals/KTableKTableRightJoin.java | 2 +-
.../streams/kstream/internals/KTableSource.java | 2 +-
.../ForeignJoinSubscriptionProcessorSupplier.java | 3 +-
.../SubscriptionStoreReceiveProcessorSupplier.java | 2 +-
.../streams/kstream/internals/metrics/Sensors.java | 26 +-
.../processor/internals/GlobalStateUpdateTask.java | 2 +-
.../processor/internals/GlobalStreamThread.java | 20 +-
.../streams/processor/internals/ProcessorNode.java | 48 +++-
.../streams/processor/internals/RecordQueue.java | 3 +-
.../streams/processor/internals/StandbyTask.java | 3 +-
.../streams/processor/internals/StreamTask.java | 33 ++-
.../streams/processor/internals/StreamThread.java | 64 ++---
.../internals/metrics/StreamsMetricsImpl.java | 273 +++++++++++++++------
.../processor/internals/metrics/ThreadMetrics.java | 170 +++++++------
.../AbstractRocksDBSegmentedBytesStore.java | 4 +-
.../state/internals/InMemorySessionStore.java | 4 +-
.../state/internals/InMemoryWindowStore.java | 4 +-
.../streams/state/internals/KeyValueSegments.java | 2 +-
.../state/internals/MeteredKeyValueStore.java | 119 ++++++++-
.../state/internals/MeteredSessionStore.java | 70 +++++-
.../state/internals/MeteredWindowStore.java | 58 ++++-
.../kafka/streams/state/internals/NamedCache.java | 9 +-
.../streams/state/internals/RocksDBStore.java | 2 +-
.../state/internals/TimestampedSegments.java | 2 +-
.../state/internals/metrics/NamedCacheMetrics.java | 8 +-
.../state/internals/metrics/RocksDBMetrics.java | 159 +++++++++---
.../internals/metrics/RocksDBMetricsRecorder.java | 9 +-
.../streams/state/internals/metrics/Sensors.java | 18 +-
.../org/apache/kafka/streams/KafkaStreamsTest.java | 36 ++-
.../integration/MetricsIntegrationTest.java | 57 ++++-
.../internals/metrics/ClientMetricsTest.java | 137 +++++++++++
...KStreamSessionWindowAggregateProcessorTest.java | 11 +-
.../internals/KStreamWindowAggregateTest.java | 9 +-
.../KTableSuppressProcessorMetricsTest.java | 65 ++---
.../internals/GlobalStreamThreadTest.java | 11 +-
.../processor/internals/ProcessorNodeTest.java | 7 +-
.../processor/internals/StandbyTaskTest.java | 3 +-
.../processor/internals/StreamTaskTest.java | 20 +-
.../processor/internals/StreamThreadTest.java | 190 +++++++-------
.../internals/metrics/StreamsMetricsImplTest.java | 237 +++++++++++++++---
.../internals/metrics/ThreadMetricsTest.java | 49 ++--
.../AbstractRocksDBSegmentedBytesStoreTest.java | 5 +-
.../state/internals/KeyValueSegmentTest.java | 3 +-
.../state/internals/MeteredKeyValueStoreTest.java | 6 +-
.../state/internals/MeteredSessionStoreTest.java | 7 +-
.../MeteredTimestampedKeyValueStoreTest.java | 7 +-
.../state/internals/MeteredWindowStoreTest.java | 5 +-
.../state/internals/SegmentIteratorTest.java | 3 +-
.../state/internals/SessionBytesStoreTest.java | 5 +-
.../state/internals/TimestampedSegmentTest.java | 3 +-
.../state/internals/WindowBytesStoreTest.java | 5 +-
.../internals/metrics/NamedCacheMetricsTest.java | 16 +-
.../metrics/RocksDBMetricsRecorderTest.java | 5 +-
.../internals/metrics/RocksDBMetricsTest.java | 21 +-
.../apache/kafka/streams/TopologyTestDriver.java | 11 +-
.../streams/processor/MockProcessorContext.java | 6 +-
67 files changed, 1625 insertions(+), 590 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/internals/metrics/ClientMetrics.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/internals/metrics/ClientMetricsTest.java
