This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from f0c3d93104c KAFKA-19597: Stop the RSM after closing the remote-log
reader threads to handle requests gracefully (#20342)
add 8dec45ff873 MINOR: Cleanup Connect Module (3/n) (#20156)
No new revisions were added by this update.
Summary of changes:
...oneConnectorClientConfigOverridePolicyTest.java | 3 +-
...palConnectorClientConfigOverridePolicyTest.java | 4 +-
.../connect/converters/BooleanConverterTest.java | 4 +-
.../connect/converters/ByteArrayConverterTest.java | 4 +-
.../connect/integration/BlockingConnectorTest.java | 3 +-
.../integration/ConnectWorkerIntegrationTest.java | 55 +-
.../kafka/connect/integration/ConnectorHandle.java | 18 +-
.../ConnectorRestartApiIntegrationTest.java | 7 +-
.../ConnectorTopicsIntegrationTest.java | 43 +-
.../ExactlyOnceSourceIntegrationTest.java | 35 +-
.../integration/InternalTopicsIntegrationTest.java | 7 +-
.../integration/OffsetsApiIntegrationTest.java | 26 +-
.../RebalanceSourceConnectorsIntegrationTest.java | 5 +-
.../integration/RestExtensionIntegrationTest.java | 3 +-
.../integration/RestForwardingIntegrationTest.java | 3 +-
.../integration/SinkConnectorsIntegrationTest.java | 8 +-
.../SourceConnectorsIntegrationTest.java | 3 +-
.../StandaloneWorkerIntegrationTest.java | 18 +-
.../connect/integration/StartAndStopLatchTest.java | 5 +-
.../integration/TestableSourceConnector.java | 10 +-
.../integration/TransformationIntegrationTest.java | 5 +-
.../kafka/connect/runtime/AbstractHerderTest.java | 128 ++--
.../runtime/AbstractWorkerSourceTaskTest.java | 116 ++--
.../kafka/connect/runtime/ConnectorConfigTest.java | 5 +-
.../connect/runtime/ErrorHandlingTaskTest.java | 37 +-
.../runtime/ExactlyOnceWorkerSourceTaskTest.java | 27 +-
.../connect/runtime/InternalSinkRecordTest.java | 4 +-
.../kafka/connect/runtime/MockLoggersTest.java | 8 +-
.../runtime/SourceTaskOffsetCommitterTest.java | 3 +-
.../connect/runtime/SubmittedRecordsTest.java | 41 +-
.../connect/runtime/TransformationStageTest.java | 7 +-
.../kafka/connect/runtime/WorkerConfigTest.java | 7 +-
.../runtime/WorkerConfigTransformerTest.java | 19 +-
.../kafka/connect/runtime/WorkerSinkTaskTest.java | 113 ++--
.../runtime/WorkerSinkTaskThreadedTest.java | 23 +-
.../connect/runtime/WorkerSourceTaskTest.java | 38 +-
.../apache/kafka/connect/runtime/WorkerTest.java | 241 ++++---
.../kafka/connect/runtime/WorkerTestUtils.java | 10 +-
.../ConnectProtocolCompatibilityTest.java | 68 +-
.../runtime/distributed/DistributedConfigTest.java | 13 +-
.../runtime/distributed/DistributedHerderTest.java | 710 ++++++++++-----------
.../IncrementalCooperativeAssignorTest.java | 94 ++-
.../WorkerCoordinatorIncrementalTest.java | 120 ++--
.../runtime/distributed/WorkerCoordinatorTest.java | 109 ++--
.../connect/runtime/errors/ErrorReporterTest.java | 22 +-
.../errors/RetryWithToleranceOperatorTest.java | 27 +-
.../errors/WorkerErrantRecordReporterTest.java | 6 +-
.../health/ConnectClusterStateImplTest.java | 7 +-
.../isolation/DelegatingClassLoaderTest.java | 19 +-
.../runtime/isolation/MultiVersionTest.java | 3 +-
.../runtime/isolation/PluginRecommenderTest.java | 11 +-
.../runtime/isolation/PluginScannerTest.java | 13 +-
.../connect/runtime/isolation/PluginUtilsTest.java | 74 +--
.../connect/runtime/isolation/PluginsTest.java | 51 +-
.../runtime/isolation/SamplingTestPlugin.java | 5 +-
.../runtime/isolation/SynchronizationTest.java | 7 +-
.../connect/runtime/isolation/TestPlugins.java | 8 +-
.../runtime/isolation/VersionedPluginBuilder.java | 4 +-
.../runtime/rest/ConnectRestServerTest.java | 18 +-
.../connect/runtime/rest/RestServerConfigTest.java | 12 +-
.../rest/entities/ConnectorOffsetsTest.java | 4 +-
.../rest/entities/CreateConnectorRequestTest.java | 4 +-
.../resources/ConnectorPluginsResourceTest.java | 36 +-
.../rest/resources/ConnectorsResourceTest.java | 64 +-
.../resources/InternalConnectResourceTest.java | 5 +-
.../rest/resources/LoggingResourceTest.java | 12 +-
.../connect/runtime/rest/util/SSLUtilsTest.java | 6 +-
.../runtime/standalone/StandaloneHerderTest.java | 198 +++---
.../storage/ConnectorOffsetBackingStoreTest.java | 4 +-
.../storage/FileOffsetBackingStoreTest.java | 38 +-
.../storage/KafkaConfigBackingStoreTest.java | 162 +++--
.../storage/KafkaOffsetBackingStoreTest.java | 46 +-
.../storage/KafkaStatusBackingStoreFormatTest.java | 8 +-
.../storage/MemoryConfigBackingStoreTest.java | 24 +-
.../storage/MemoryStatusBackingStoreTest.java | 5 +-
.../connect/storage/OffsetStorageWriterTest.java | 4 +-
.../kafka/connect/storage/OffsetUtilsTest.java | 20 +-
.../kafka/connect/util/ConnectUtilsTest.java | 5 +-
.../kafka/connect/util/KafkaBasedLogTest.java | 3 +-
.../kafka/connect/util/SharedTopicAdminTest.java | 3 +-
.../apache/kafka/connect/util/SinkUtilsTest.java | 3 +-
.../org/apache/kafka/connect/util/TableTest.java | 1 -
.../apache/kafka/connect/util/TopicAdminTest.java | 81 ++-
.../kafka/connect/util/TopicCreationTest.java | 59 +-
.../connect/util/clusters/EmbeddedConnect.java | 23 +-
.../util/clusters/EmbeddedConnectStandalone.java | 5 +-
.../util/clusters/EmbeddedKafkaCluster.java | 35 +-
.../test/plugins/ReadVersionFromResource.java | 6 +-
.../test/plugins/ReadVersionFromResource.java | 6 +-
89 files changed, 1632 insertions(+), 1735 deletions(-)
