This is an automated email from the ASF dual-hosted git repository.
kkarantasis pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 131d475 KAFKA-12193: Re-resolve IPs after a client disconnects (#9902)
add c19a35d KAFKA-10835: Replace Runnable and Callable overrides with
lambdas in Connect (#9867)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/data/ConnectSchemaTest.java | 3 +-
.../kafka/connect/header/ConnectHeadersTest.java | 20 +-
.../apache/kafka/connect/json/JsonConverter.java | 170 +++-----
.../connect/mirror/MirrorCheckpointConnector.java | 2 +-
.../kafka/connect/mirror/MirrorCheckpointTask.java | 2 +-
.../apache/kafka/connect/mirror/MirrorMaker.java | 4 +-
.../kafka/connect/mirror/MirrorMakerConfig.java | 7 +-
.../apache/kafka/connect/mirror/MirrorMetrics.java | 2 +-
.../connect/mirror/MirrorSourceConnector.java | 15 +-
.../kafka/connect/mirror/MirrorSourceTask.java | 2 +-
.../mirror/MirrorCheckpointConnectorTest.java | 2 +-
.../MirrorConnectorsIntegrationBaseTest.java | 2 +-
.../kafka/connect/cli/ConnectStandalone.java | 14 +-
.../connect/runtime/SourceTaskOffsetCommitter.java | 9 +-
.../connect/runtime/WorkerConfigTransformer.java | 9 +-
.../kafka/connect/runtime/WorkerSinkTask.java | 7 +-
.../apache/kafka/connect/runtime/WorkerTask.java | 20 +-
.../runtime/distributed/DistributedHerder.java | 435 +++++++++------------
.../IncrementalCooperativeAssignor.java | 5 +-
.../runtime/distributed/WorkerCoordinator.java | 27 +-
.../runtime/isolation/DelegatingClassLoader.java | 43 +-
.../connect/runtime/isolation/PluginUtils.java | 9 +-
.../runtime/standalone/StandaloneHerder.java | 4 +-
.../connect/storage/KafkaConfigBackingStore.java | 23 +-
.../connect/storage/KafkaOffsetBackingStore.java | 23 +-
.../connect/storage/KafkaStatusBackingStore.java | 30 +-
.../connect/storage/MemoryOffsetBackingStore.java | 32 +-
.../kafka/connect/storage/OffsetStorageWriter.java | 11 +-
.../apache/kafka/connect/tools/MockConnector.java | 9 +-
.../apache/kafka/connect/util/KafkaBasedLog.java | 6 +-
.../kafka/connect/runtime/AbstractHerderTest.java | 8 +-
.../kafka/connect/runtime/WorkerSinkTaskTest.java | 297 ++++++--------
.../runtime/WorkerSinkTaskThreadedTest.java | 198 ++++------
.../connect/runtime/WorkerSourceTaskTest.java | 92 ++---
.../WorkerSourceTaskWithTopicCreationTest.java | 92 ++---
.../kafka/connect/runtime/WorkerTaskTest.java | 23 +-
.../runtime/distributed/DistributedConfigTest.java | 24 +-
.../runtime/distributed/DistributedHerderTest.java | 328 ++++++----------
.../runtime/distributed/WorkerCoordinatorTest.java | 40 +-
.../health/ConnectClusterStateImplTest.java | 30 +-
.../rest/resources/ConnectorsResourceTest.java | 14 +-
.../runtime/standalone/StandaloneHerderTest.java | 37 +-
.../storage/KafkaConfigBackingStoreTest.java | 41 +-
.../storage/KafkaOffsetBackingStoreTest.java | 63 +--
.../storage/KafkaStatusBackingStoreTest.java | 68 ++--
.../connect/storage/OffsetStorageWriterTest.java | 32 +-
.../kafka/connect/util/KafkaBasedLogTest.java | 259 +++++-------
.../apache/kafka/connect/util/TopicAdminTest.java | 12 +-
.../kafka/connect/transforms/TimestampRouter.java | 13 +-
.../transforms/predicates/HasHeaderKeyTest.java | 2 +-
50 files changed, 983 insertions(+), 1637 deletions(-)
