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 c1ded050672 KAFKA-19446: Propagate transaction version info to
producer epoch check [3/3] (#20882)
add bb95e3ab195 KAFKA-19882: Cleaning client level metric tags (#20906)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 6 +-
.../streams/internals/metrics/ClientMetrics.java | 18 +-
.../internals/metrics/StreamsMetricsImpl.java | 44 +++-
.../internals/metrics/ClientMetricsTest.java | 35 ++-
...KStreamSessionWindowAggregateProcessorTest.java | 2 +-
.../processor/internals/ActiveTaskCreatorTest.java | 2 +-
.../internals/DefaultStateUpdaterTest.java | 2 +-
.../internals/GlobalStreamThreadTest.java | 6 +-
.../processor/internals/MockStreamsMetrics.java | 2 +-
.../processor/internals/ProcessorNodeTest.java | 6 +-
.../processor/internals/RecordQueueTest.java | 2 +-
.../processor/internals/SourceNodeTest.java | 2 +-
.../processor/internals/StandbyTaskTest.java | 2 +-
.../processor/internals/StateDirectoryTest.java | 2 +-
.../processor/internals/StreamTaskTest.java | 10 +-
.../processor/internals/StreamThreadTest.java | 50 ++--
.../internals/metrics/StreamsMetricsImplTest.java | 260 ++++++++++++---------
...ctDualSchemaRocksDBSegmentedBytesStoreTest.java | 8 +-
.../AbstractRocksDBSegmentedBytesStoreTest.java | 8 +-
.../ChangeLoggingKeyValueBytesStoreTest.java | 2 +-
.../internals/GlobalStateStoreProviderTest.java | 2 +-
.../state/internals/KeyValueSegmentTest.java | 2 +-
.../state/internals/MeteredKeyValueStoreTest.java | 2 +-
.../state/internals/MeteredSessionStoreTest.java | 2 +-
.../MeteredTimestampedKeyValueStoreTest.java | 2 +-
.../MeteredTimestampedWindowStoreTest.java | 4 +-
.../MeteredVersionedKeyValueStoreTest.java | 2 +-
.../state/internals/MeteredWindowStoreTest.java | 2 +-
.../streams/state/internals/RocksDBStoreTest.java | 6 +-
.../RocksDBTimeOrderedKeyValueBufferTest.java | 2 +-
.../state/internals/TimestampedSegmentTest.java | 2 +-
.../metrics/RocksDBMetricsRecorderGaugesTest.java | 6 +-
.../metrics/RocksDBMetricsRecorderTest.java | 2 +-
.../kafka/test/InternalMockProcessorContext.java | 12 +-
.../apache/kafka/streams/TopologyTestDriver.java | 2 -
.../streams/processor/MockProcessorContext.java | 2 -
.../processor/api/MockProcessorContext.java | 2 -
.../kafka/streams/MockProcessorContextTest.java | 2 -
38 files changed, 292 insertions(+), 233 deletions(-)
