This is an automated email from the ASF dual-hosted git repository.
frankvicky pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 270948bf9d7 KAFKA-19115: Utilize initialized topics info to verify
delete share group offsets (#19431)
add b3bc674d32c MINOR: Cleanups in connect:runtime (#19452)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/runtime/AbstractHerder.java | 9 +--
.../kafka/connect/runtime/CachedConnectors.java | 4 +-
.../kafka/connect/runtime/ConnectorConfig.java | 20 +----
.../runtime/ExactlyOnceWorkerSourceTask.java | 41 +++++-----
.../org/apache/kafka/connect/runtime/Herder.java | 32 +-------
.../apache/kafka/connect/runtime/RestartPlan.java | 13 +---
.../kafka/connect/runtime/RestartRequest.java | 72 +++--------------
.../apache/kafka/connect/runtime/SessionKey.java | 51 ++-----------
.../kafka/connect/runtime/SubmittedRecords.java | 89 +++++-----------------
.../org/apache/kafka/connect/runtime/Worker.java | 6 +-
.../distributed/ConnectProtocolCompatibility.java | 16 ++--
.../runtime/distributed/DistributedHerder.java | 11 ++-
.../IncrementalCooperativeAssignor.java | 3 +-
.../runtime/distributed/WorkerCoordinator.java | 15 ++--
.../runtime/errors/DeadLetterQueueReporter.java | 4 +-
.../runtime/errors/RetryWithToleranceOperator.java | 2 +-
.../runtime/health/ConnectClusterDetailsImpl.java | 13 +---
.../runtime/isolation/DelegatingClassLoader.java | 2 +-
.../connect/runtime/isolation/PluginScanner.java | 2 +-
.../connect/runtime/isolation/PluginSource.java | 33 +-------
.../connect/runtime/isolation/PluginUtils.java | 11 +--
.../kafka/connect/runtime/isolation/Plugins.java | 1 -
.../runtime/isolation/PluginsRecommenders.java | 1 -
.../rest/ConnectRestExtensionContextImpl.java | 24 +-----
.../connect/runtime/rest/HerderRequestHandler.java | 2 +-
.../kafka/connect/runtime/rest/RestClient.java | 23 +-----
.../rest/resources/ConnectorPluginsResource.java | 9 +--
.../runtime/rest/resources/ConnectorsResource.java | 16 ++--
.../rest/resources/InternalClusterResource.java | 2 +-
.../runtime/standalone/StandaloneHerder.java | 42 +++++-----
.../storage/ConnectorOffsetBackingStore.java | 2 +-
.../connect/storage/KafkaConfigBackingStore.java | 9 +--
.../connect/storage/KafkaOffsetBackingStore.java | 2 +-
.../connect/storage/MemoryConfigBackingStore.java | 5 --
.../connect/storage/PrivilegedWriteException.java | 3 -
.../apache/kafka/connect/tools/PredicateDoc.java | 3 +-
.../kafka/connect/tools/TransformationDoc.java | 11 +--
.../apache/kafka/connect/util/ConnectorTaskId.java | 30 +-------
.../ExactlyOnceSourceIntegrationTest.java | 2 +-
.../RebalanceSourceConnectorsIntegrationTest.java | 7 +-
.../kafka/connect/integration/StartsAndStops.java | 18 +----
.../integration/TestableSourceConnector.java | 34 +++------
.../kafka/connect/runtime/AbstractHerderTest.java | 8 +-
.../runtime/AbstractWorkerSourceTaskTest.java | 4 +-
.../kafka/connect/runtime/WorkerConnectorTest.java | 16 ++--
.../apache/kafka/connect/runtime/WorkerTest.java | 16 ++--
.../kafka/connect/runtime/WorkerTestUtils.java | 5 +-
.../connect/runtime/errors/ErrorReporterTest.java | 4 +-
.../errors/RetryWithToleranceOperatorTest.java | 14 ++--
.../runtime/isolation/SynchronizationTest.java | 1 -
.../connect/runtime/isolation/TestPlugins.java | 10 +--
.../kafka/connect/runtime/rest/RestClientTest.java | 21 +----
.../connect/runtime/rest/util/SSLUtilsTest.java | 9 +--
.../runtime/standalone/StandaloneHerderTest.java | 10 +--
.../connect/util/clusters/EmbeddedConnect.java | 2 +-
.../util/clusters/EmbeddedConnectCluster.java | 2 +-
56 files changed, 203 insertions(+), 614 deletions(-)
