[kafka] branch trunk updated (81e709c -> 8047ba3)

[mi...@apache.org]

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 81e709c  MINOR: Remove unused params in `ZkConfigManager` (#11763)
     add 8047ba3  MINOR: Small cleanups in connect:runtime (#11756)

No new revisions were added by this update.

Summary of changes:
 ...bstractConnectorClientConfigOverridePolicy.java |  2 +-
 .../kafka/connect/converters/NumberConverter.java  |  3 +--
 .../kafka/connect/runtime/AbstractHerder.java      |  4 ++--
 .../kafka/connect/runtime/ConnectMetrics.java      |  2 +-
 .../kafka/connect/runtime/ConnectorConfig.java     |  4 ++--
 .../connect/runtime/PredicatedTransformation.java  |  6 +++---
 .../kafka/connect/runtime/SinkConnectorConfig.java |  8 ++++----
 .../connect/runtime/SourceConnectorConfig.java     |  8 ++++----
 .../apache/kafka/connect/runtime/TaskConfig.java   |  6 +++---
 .../org/apache/kafka/connect/runtime/Worker.java   |  1 -
 .../apache/kafka/connect/runtime/WorkerConfig.java |  4 ++--
 .../kafka/connect/runtime/WorkerSinkTask.java      |  6 +++---
 .../connect/runtime/WorkerSinkTaskContext.java     |  6 +++---
 .../runtime/distributed/DistributedHerder.java     |  2 +-
 .../connect/runtime/distributed/EagerAssignor.java | 12 ++----------
 .../IncrementalCooperativeAssignor.java            |  2 +-
 .../runtime/distributed/WorkerCoordinator.java     |  2 +-
 .../runtime/errors/DeadLetterQueueReporter.java    |  2 +-
 .../kafka/connect/runtime/errors/LogReporter.java  |  2 +-
 .../runtime/health/ConnectClusterStateImpl.java    |  3 +--
 .../runtime/isolation/DelegatingClassLoader.java   |  6 ++----
 .../connect/runtime/isolation/PluginType.java      |  2 +-
 .../kafka/connect/runtime/isolation/Plugins.java   | 11 -----------
 .../runtime/rest/ConnectRestConfigurable.java      |  2 +-
 .../rest/ConnectRestExtensionContextImpl.java      |  4 ++--
 .../kafka/connect/runtime/rest/RestClient.java     |  6 +++---
 .../kafka/connect/runtime/rest/RestServer.java     |  4 ++--
 .../connect/runtime/rest/entities/ConfigInfo.java  |  4 ++--
 .../connect/runtime/rest/entities/ConfigInfos.java |  2 +-
 .../runtime/rest/entities/ConfigKeyInfo.java       |  2 +-
 .../runtime/rest/entities/ConfigValueInfo.java     | 12 ++++++------
 .../runtime/rest/entities/ConnectorPluginInfo.java |  6 +++---
 .../runtime/rest/resources/ConnectorsResource.java |  2 +-
 .../connect/storage/KafkaConfigBackingStore.java   |  6 +-----
 .../connect/storage/KafkaStatusBackingStore.java   |  2 +-
 .../connect/storage/MemoryConfigBackingStore.java  |  2 +-
 .../connect/storage/MemoryOffsetBackingStore.java  |  4 +---
 .../kafka/connect/tools/MockSinkConnector.java     |  2 +-
 .../kafka/connect/tools/MockSourceConnector.java   |  2 +-
 .../apache/kafka/connect/tools/MockSourceTask.java |  2 +-
 .../apache/kafka/connect/tools/PredicateDoc.java   |  2 +-
 .../kafka/connect/tools/SchemaSourceTask.java      | 19 +++++++++----------
 .../kafka/connect/tools/VerifiableSourceTask.java  |  4 ++--
 .../apache/kafka/connect/util/KafkaBasedLog.java   |  6 +++---
 .../apache/kafka/connect/util/LoggingContext.java  |  4 ++--
 .../kafka/connect/util/ShutdownableThread.java     |  6 +++---
 .../java/org/apache/kafka/connect/util/Table.java  |  8 ++------
 .../org/apache/kafka/connect/util/TopicAdmin.java  |  2 +-
 .../connect/converters/ByteArrayConverterTest.java |  6 ++----
 .../ConnectorRestartApiIntegrationTest.java        |  2 +-
 .../integration/MonitorableSourceConnector.java    |  4 ++--
 .../RebalanceSourceConnectorsIntegrationTest.java  |  4 ++--
 .../kafka/connect/runtime/AbstractHerderTest.java  |  9 ++++-----
 .../kafka/connect/runtime/ConnectMetricsTest.java  |  1 -
 .../connect/runtime/ErrorHandlingTaskTest.java     |  2 +-
 .../kafka/connect/runtime/MockConnectMetrics.java  |  1 -
 .../kafka/connect/runtime/WorkerConnectorTest.java |  2 +-
 .../kafka/connect/runtime/WorkerSinkTaskTest.java  |  4 ++--
 .../runtime/WorkerSinkTaskThreadedTest.java        | 13 ++++++-------
 .../connect/runtime/WorkerSourceTaskTest.java      | 10 +++++-----
 .../apache/kafka/connect/runtime/WorkerTest.java   |  3 +--
 .../ConnectProtocolCompatibilityTest.java          | 17 +++++++++--------
 .../runtime/distributed/DistributedHerderTest.java | 19 +++++++++----------
 .../runtime/distributed/WorkerCoordinatorTest.java | 22 +++++++++++-----------
 .../isolation/DelegatingClassLoaderTest.java       |  4 ++--
 .../connect/runtime/isolation/PluginsTest.java     |  7 ++-----
 .../runtime/isolation/SynchronizationTest.java     |  2 +-
 .../kafka/connect/runtime/rest/RestServerTest.java |  1 -
 .../resources/ConnectorPluginsResourceTest.java    |  5 +----
 .../rest/resources/ConnectorsResourceTest.java     | 22 +++++++++++-----------
 .../runtime/standalone/StandaloneHerderTest.java   |  4 ++--
 .../storage/KafkaConfigBackingStoreTest.java       | 11 +++++------
 .../storage/KafkaOffsetBackingStoreTest.java       |  3 +--
 .../kafka/connect/util/KafkaBasedLogTest.java      |  6 +-----
 .../kafka/connect/util/SharedTopicAdminTest.java   |  2 +-
 .../apache/kafka/connect/util/TopicAdminTest.java  | 20 +++++---------------
 76 files changed, 180 insertions(+), 245 deletions(-)