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 36c131ef4a2 KAFKA-17609:[1/4] Changes needed to convert system tests
to use KRaft and remove ZK (#17275)
add 4ed0a958e54 KAFKA-17248 - KIP 1076 implementation (#17021)
No new revisions were added by this update.
Summary of changes:
build.gradle | 3 +-
checkstyle/import-control.xml | 5 +
.../kafka/clients/admin/KafkaAdminClient.java | 76 ++--
.../kafka/clients/consumer/KafkaConsumer.java | 50 +-
.../consumer/internals/AsyncKafkaConsumer.java | 10 +-
.../consumer/internals/ClassicKafkaConsumer.java | 10 +-
.../kafka/clients/producer/KafkaProducer.java | 48 ++
.../kafka/clients/producer/MockProducer.java | 18 +-
.../apache/kafka/clients/producer/Producer.java | 11 +
.../kafka/clients/admin/KafkaAdminClientTest.java | 65 ++-
.../KafkaStreamsTelemetryIntegrationTest.java | 506 +++++++++++++++++++++
.../TestingMetricsInterceptingAdminClient.java | 6 +-
.../org/apache/kafka/streams/KafkaStreams.java | 4 +
.../org/apache/kafka/streams/StreamsConfig.java | 4 +-
.../streams/processor/internals/StreamThread.java | 13 +-
.../apache/kafka/streams/StreamsConfigTest.java | 2 +-
16 files changed, 749 insertions(+), 82 deletions(-)
create mode 100644
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java
