This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 4271fd8c8b1 KAFKA-19564: Close Consumer in ConsumerPerformance only
after metrics displayed (#20267)
add dd52058466b MINOR: Cleanups in Connect (#20077)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/file/FileStreamSinkTaskTest.java | 2 +-
.../apache/kafka/connect/json/JsonConverter.java | 2 --
.../kafka/connect/mirror/MirrorCheckpointTask.java | 2 +-
.../apache/kafka/connect/mirror/MirrorMaker.java | 2 +-
.../kafka/connect/mirror/MirrorMakerConfig.java | 2 +-
.../apache/kafka/connect/mirror/OffsetSync.java | 24 +---------------------
.../kafka/connect/mirror/CheckpointStoreTest.java | 7 ++-----
.../mirror/MirrorCheckpointConnectorTest.java | 5 ++---
.../DedicatedMirrorIntegrationTest.java | 6 +++---
.../IdentityReplicationIntegrationTest.java | 10 ++++-----
.../MirrorConnectorsIntegrationBaseTest.java | 4 ++--
...MirrorConnectorsIntegrationExactlyOnceTest.java | 2 +-
...rsWithCustomForwardingAdminIntegrationTest.java | 2 +-
.../runtime/WorkerSinkTaskThreadedTest.java | 17 +++------------
.../transforms/predicates/HasHeaderKeyTest.java | 13 +-----------
15 files changed, 25 insertions(+), 75 deletions(-)
