This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d046994 KAFKA-8981 Add rate limiting to NetworkDegradeSpec (#7446)
add 19681f6 KAFKA-9086: Refactor processor-node-level metrics (#7615)
No new revisions were added by this update.
Summary of changes:
.../internals/KStreamSessionWindowAggregate.java | 14 +-
.../kstream/internals/KStreamWindowAggregate.java | 16 +-
.../streams/kstream/internals/metrics/Sensors.java | 93 -----
.../suppress/KTableSuppressProcessorSupplier.java | 9 +-
.../streams/processor/internals/ProcessorNode.java | 187 +++------
.../streams/processor/internals/SourceNode.java | 11 +-
.../streams/processor/internals/StreamTask.java | 29 +-
.../streams/processor/internals/StreamThread.java | 7 +-
.../internals/metrics/ProcessorNodeMetrics.java | 420 +++++++++++++++++++++
.../internals/metrics/StreamsMetricsImpl.java | 6 +-
.../processor/internals/metrics/TaskMetrics.java | 12 +-
.../processor/internals/metrics/ThreadMetrics.java | 72 ++--
.../state/internals/metrics/StateStoreMetrics.java | 1 -
.../integration/MetricsIntegrationTest.java | 91 ++---
...KStreamSessionWindowAggregateProcessorTest.java | 224 ++++++-----
.../internals/KStreamWindowAggregateTest.java | 162 +++++---
.../kstream/internals/metrics/TaskMetricsTest.java | 34 +-
.../KTableSuppressProcessorMetricsTest.java | 12 +-
.../processor/internals/ProcessorNodeTest.java | 107 +++---
.../processor/internals/SourceNodeTest.java | 59 +++
.../metrics/ProcessorNodeMetricsTest.java | 383 +++++++++++++++++++
.../internals/metrics/StreamsMetricsImplTest.java | 26 +-
.../internals/metrics/ThreadMetricsTest.java | 56 ++-
.../kafka/test/InternalMockProcessorContext.java | 12 +
.../org/apache/kafka/test/StreamsTestUtils.java | 9 +
25 files changed, 1466 insertions(+), 586 deletions(-)
delete mode 100644
streams/src/main/java/org/apache/kafka/streams/kstream/internals/metrics/Sensors.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetricsTest.java
