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 77fc498 KAFKA-8992; Redefine RemoveMembersFromGroup interface on
AdminClient (#7478)
add 27ba8f5 KAFKA-8968: Refactor task-level metrics (#7566)
No new revisions were added by this update.
Summary of changes:
.../kstream/internals/KStreamAggregate.java | 10 +-
.../kstream/internals/KStreamKStreamJoin.java | 10 +-
.../internals/KStreamKTableJoinProcessor.java | 11 +-
.../streams/kstream/internals/KStreamReduce.java | 10 +-
.../internals/KStreamSessionWindowAggregate.java | 11 +-
.../kstream/internals/KStreamWindowAggregate.java | 9 +-
.../kstream/internals/KTableKTableInnerJoin.java | 10 +-
.../kstream/internals/KTableKTableLeftJoin.java | 10 +-
.../kstream/internals/KTableKTableOuterJoin.java | 10 +-
.../kstream/internals/KTableKTableRightJoin.java | 10 +-
.../streams/kstream/internals/KTableSource.java | 10 +-
.../ForeignJoinSubscriptionProcessorSupplier.java | 14 +-
...reignJoinSubscriptionSendProcessorSupplier.java | 18 +-
.../SubscriptionStoreReceiveProcessorSupplier.java | 17 +-
.../streams/kstream/internals/metrics/Sensors.java | 39 +--
.../processor/internals/GlobalStateUpdateTask.java | 9 +-
.../streams/processor/internals/ProcessorNode.java | 11 +-
.../processor/internals/RecordCollectorImpl.java | 9 +-
.../processor/internals/RecordDeserializer.java | 10 +-
.../streams/processor/internals/RecordQueue.java | 17 +-
.../streams/processor/internals/StreamTask.java | 126 ++++------
.../internals/metrics/StreamsMetricsImpl.java | 31 ++-
.../processor/internals/metrics/TaskMetrics.java | 268 +++++++++++++++++++++
.../processor/internals/metrics/ThreadMetrics.java | 25 +-
.../integration/MetricsIntegrationTest.java | 18 ++
...KStreamSessionWindowAggregateProcessorTest.java | 12 +-
.../kstream/internals/metrics/TaskMetricsTest.java | 263 ++++++++++++++++++++
.../processor/internals/ProcessorNodeTest.java | 3 +-
.../processor/internals/RecordCollectorTest.java | 33 ++-
.../internals/RecordDeserializerTest.java | 3 +-
.../processor/internals/RecordQueueTest.java | 5 +-
.../streams/processor/internals/SinkNodeTest.java | 4 +-
.../processor/internals/StreamTaskTest.java | 120 +++++----
.../processor/internals/StreamThreadTest.java | 1 +
.../internals/metrics/StreamsMetricsImplTest.java | 68 ++++--
.../internals/metrics/ThreadMetricsTest.java | 44 ++--
.../streams/state/KeyValueStoreTestDriver.java | 3 +-
.../state/internals/SessionBytesStoreTest.java | 3 +-
.../state/internals/StoreChangeLoggerTest.java | 3 +-
.../state/internals/WindowBytesStoreTest.java | 3 +-
.../apache/kafka/streams/TopologyTestDriver.java | 4 +-
.../streams/processor/MockProcessorContext.java | 4 +-
42 files changed, 917 insertions(+), 382 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/kstream/internals/metrics/TaskMetricsTest.java
