[kafka] branch trunk updated (054d5f9 -> cfe642e)

[ca...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cadonna pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 054d5f9  MINOR: fix code listings security.html (#10770)
     add cfe642e  KAFKA-12519: Remove built-in Streams metrics for versions 0.10.0-2.4 (#10765)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/StreamsConfig.java    |   6 -
 .../kstream/internals/KStreamAggregate.java        |   4 +-
 .../kstream/internals/KStreamKStreamJoin.java      |   4 +-
 .../internals/KStreamKTableJoinProcessor.java      |   4 +-
 .../streams/kstream/internals/KStreamReduce.java   |   4 +-
 .../internals/KStreamSessionWindowAggregate.java   |   9 +-
 .../internals/KStreamSlidingWindowAggregate.java   |   8 +-
 .../kstream/internals/KStreamWindowAggregate.java  |   8 +-
 .../kstream/internals/KTableKTableInnerJoin.java   |   4 +-
 .../kstream/internals/KTableKTableLeftJoin.java    |   4 +-
 .../kstream/internals/KTableKTableOuterJoin.java   |   4 +-
 .../kstream/internals/KTableKTableRightJoin.java   |   4 +-
 .../streams/kstream/internals/KTableSource.java    |   4 +-
 .../ForeignJoinSubscriptionProcessorSupplier.java  |   2 +-
 ...reignJoinSubscriptionSendProcessorSupplier.java |   2 +-
 .../SubscriptionStoreReceiveProcessorSupplier.java |   2 +-
 .../processor/internals/GlobalStateUpdateTask.java |   4 +-
 .../streams/processor/internals/ProcessorNode.java |  50 +---
 .../processor/internals/RecordCollectorImpl.java   |   2 +-
 .../streams/processor/internals/RecordQueue.java   |   2 +-
 .../streams/processor/internals/SourceNode.java    |   2 +-
 .../streams/processor/internals/StreamTask.java    |   8 +-
 .../streams/processor/internals/StreamThread.java  |   7 +-
 .../internals/metrics/ProcessorNodeMetrics.java    | 235 ------------------
 .../internals/metrics/StreamsMetricsImpl.java      |  25 +-
 .../processor/internals/metrics/TaskMetrics.java   |  87 ++-----
 .../processor/internals/metrics/ThreadMetrics.java |  33 +--
 .../AbstractRocksDBSegmentedBytesStore.java        |   4 +-
 .../state/internals/InMemorySessionStore.java      |   4 +-
 .../InMemoryTimeOrderedKeyValueBuffer.java         |   4 -
 .../state/internals/InMemoryWindowStore.java       |   4 +-
 .../state/internals/MeteredKeyValueStore.java      |  20 +-
 .../state/internals/MeteredSessionStore.java       |  14 +-
 .../state/internals/MeteredWindowStore.java        |  10 +-
 .../state/internals/metrics/NamedCacheMetrics.java |  46 +---
 .../state/internals/metrics/StateStoreMetrics.java | 181 ++------------
 .../apache/kafka/streams/StreamsConfigTest.java    |   7 -
 .../integration/MetricsIntegrationTest.java        | 269 ++++++---------------
 .../kstream/internals/KGroupedStreamImplTest.java  |  51 +---
 .../kstream/internals/KStreamKStreamJoinTest.java  |  75 +++---
 .../kstream/internals/KStreamKTableJoinTest.java   |  49 +---
 ...KStreamSessionWindowAggregateProcessorTest.java | 181 ++++----------
 .../internals/KStreamWindowAggregateTest.java      | 170 ++++---------
 .../internals/KTableKTableInnerJoinTest.java       |  21 +-
 .../internals/KTableKTableLeftJoinTest.java        |  21 +-
 .../internals/KTableKTableOuterJoinTest.java       |  21 +-
 .../internals/KTableKTableRightJoinTest.java       |  20 +-
 .../kstream/internals/KTableSourceTest.java        |  53 ----
 .../KTableSuppressProcessorMetricsTest.java        | 125 +---------
 .../processor/internals/ProcessorNodeTest.java     |  60 ++---
 .../processor/internals/SourceNodeTest.java        |  62 ++---
 .../processor/internals/StreamTaskTest.java        | 174 +++++--------
 .../processor/internals/StreamThreadTest.java      | 141 ++---------
 .../metrics/ProcessorNodeMetricsTest.java          | 190 +--------------
 .../internals/metrics/StreamsMetricsImplTest.java  |  83 +------
 .../internals/metrics/TaskMetricsTest.java         | 162 +++----------
 .../internals/metrics/ThreadMetricsTest.java       |  63 ++---
 .../AbstractRocksDBSegmentedBytesStoreTest.java    |  74 ++----
 .../internals/AbstractSessionBytesStoreTest.java   |  77 ++----
 .../internals/AbstractWindowBytesStoreTest.java    |  79 ++----
 .../state/internals/InMemorySessionStoreTest.java  |   5 -
 .../state/internals/InMemoryWindowStoreTest.java   |  11 -
 .../state/internals/MeteredKeyValueStoreTest.java  |  66 ++---
 .../state/internals/MeteredSessionStoreTest.java   |  75 +++---
 .../MeteredTimestampedKeyValueStoreTest.java       |  52 +---
 .../state/internals/MeteredWindowStoreTest.java    | 237 ++++++++----------
 .../state/internals/RocksDBSessionStoreTest.java   |   5 -
 .../state/internals/RocksDBWindowStoreTest.java    |  11 -
 .../internals/metrics/NamedCacheMetricsTest.java   |  46 +---
 .../internals/metrics/StateStoreMetricsTest.java   | 178 +++-----------
 .../apache/kafka/streams/TopologyTestDriver.java   |   2 +-
 .../streams/processor/MockProcessorContext.java    |   2 +-
 .../processor/api/MockProcessorContext.java        |   2 +-
 73 files changed, 788 insertions(+), 2947 deletions(-)