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 a0d4cbec402 KAFKA-17743: Add minBytes implementation to
DelayedShareFetch (#17539)
add c69a6b0e804 KAFKA-17248 - KIP 1076 Add process-id to get carried to
telemetry results (#17630)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/KafkaAdminClient.java | 2 +-
.../KafkaStreamsTelemetryIntegrationTest.java | 31 +++++++-
.../org/apache/kafka/streams/KafkaStreams.java | 3 +-
.../internals/metrics/StreamsMetricsImpl.java | 5 ++
...KStreamSessionWindowAggregateProcessorTest.java | 2 +-
.../processor/internals/ActiveTaskCreatorTest.java | 2 +-
.../internals/GlobalStreamThreadTest.java | 4 +-
.../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 | 8 +-
.../processor/internals/StreamThreadTest.java | 40 +++++-----
.../internals/metrics/StreamsMetricsImplTest.java | 87 +++++++++++-----------
...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 | 10 ++-
.../apache/kafka/streams/TopologyTestDriver.java | 7 +-
.../streams/processor/MockProcessorContext.java | 7 +-
.../processor/api/MockProcessorContext.java | 1 +
.../kafka/streams/MockProcessorContextTest.java | 1 +
37 files changed, 164 insertions(+), 116 deletions(-)
