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 56a3c6dde92 KAFKA-19485: Added check before sending acknowledgements
on initial epoch. (#20135)
add 27383970b62 MINOR: Cleanup Connect Module (1/n) (#19869)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/connect/data/ConnectSchema.java | 75 ++++++++++----------
.../java/org/apache/kafka/connect/data/Schema.java | 17 ++---
.../apache/kafka/connect/data/SchemaProjector.java | 57 +++++----------
.../java/org/apache/kafka/connect/data/Values.java | 69 +++++++-----------
.../kafka/connect/storage/ConverterType.java | 16 ++---
.../connector/ConnectorReconfigurationTest.java | 9 ++-
.../kafka/connect/data/ConnectSchemaTest.java | 81 +++++++++++-----------
.../org/apache/kafka/connect/data/DecimalTest.java | 4 +-
.../kafka/connect/data/SchemaBuilderTest.java | 26 ++++---
.../kafka/connect/data/SchemaProjectorTest.java | 60 ++++++++--------
.../org/apache/kafka/connect/data/StructTest.java | 22 +++---
.../org/apache/kafka/connect/data/ValuesTest.java | 39 +++++------
.../kafka/connect/header/ConnectHeadersTest.java | 7 +-
.../kafka/connect/source/SourceRecordTest.java | 5 +-
.../kafka/connect/storage/StringConverterTest.java | 6 +-
.../kafka/connect/util/ConnectorUtilsTest.java | 38 +++++-----
.../BasicAuthSecurityRestExtensionTest.java | 4 +-
.../auth/extension/JaasBasicAuthFilterTest.java | 5 +-
.../kafka/connect/file/FileStreamSourceTask.java | 2 +-
.../kafka/connect/file/FileStreamSinkTaskTest.java | 11 ++-
.../file/FileStreamSourceConnectorTest.java | 40 +++++------
.../connect/file/FileStreamSourceTaskTest.java | 25 ++++---
.../FileStreamSourceConnectorIntegrationTest.java | 5 +-
.../apache/kafka/connect/json/JsonConverter.java | 12 ++--
.../kafka/connect/json/JsonDeserializer.java | 3 +-
.../apache/kafka/connect/json/JsonSerializer.java | 3 +-
.../connect/json/JsonConverterConfigTest.java | 2 +-
.../kafka/connect/json/JsonConverterTest.java | 47 ++++++-------
.../apache/kafka/connect/mirror/MirrorClient.java | 3 +-
.../kafka/connect/mirror/MirrorClientTest.java | 28 ++++----
.../connect/mirror/ReplicationPolicyTest.java | 3 +-
.../kafka/connect/mirror/CheckpointStore.java | 3 +-
.../connect/mirror/MirrorCheckpointConnector.java | 7 +-
.../kafka/connect/mirror/MirrorCheckpointTask.java | 7 +-
.../connect/mirror/MirrorCheckpointTaskConfig.java | 3 +-
.../connect/mirror/MirrorHeartbeatConnector.java | 5 +-
.../kafka/connect/mirror/MirrorHeartbeatTask.java | 3 +-
.../apache/kafka/connect/mirror/MirrorMaker.java | 3 +-
.../kafka/connect/mirror/MirrorMakerConfig.java | 15 ++--
.../connect/mirror/MirrorSourceConnector.java | 7 +-
.../connect/mirror/MirrorSourceTaskConfig.java | 3 +-
.../apache/kafka/connect/mirror/MirrorUtils.java | 11 ++-
.../connect/mirror/rest/MirrorRestServer.java | 9 +--
.../kafka/connect/mirror/CheckpointStoreTest.java | 3 +-
.../connect/mirror/MirrorCheckpointConfigTest.java | 6 +-
.../mirror/MirrorCheckpointConnectorTest.java | 37 +++++-----
.../connect/mirror/MirrorCheckpointTaskTest.java | 40 +++++------
.../mirror/MirrorHeartBeatConnectorTest.java | 23 +++---
.../connect/mirror/MirrorHeartbeatTaskTest.java | 4 +-
.../connect/mirror/MirrorMakerConfigTest.java | 16 ++---
.../connect/mirror/MirrorSourceConfigTest.java | 3 +-
.../connect/mirror/MirrorSourceConnectorTest.java | 76 ++++++++++----------
.../kafka/connect/mirror/MirrorUtilsTest.java | 15 ++--
.../kafka/connect/mirror/OffsetSyncWriterTest.java | 8 +--
.../DedicatedMirrorIntegrationTest.java | 11 ++-
.../MirrorConnectorsIntegrationBaseTest.java | 74 ++++++++++----------
...MirrorConnectorsIntegrationExactlyOnceTest.java | 4 +-
...rsWithCustomForwardingAdminIntegrationTest.java | 18 +++--
58 files changed, 506 insertions(+), 632 deletions(-)
