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 b5fb6543a20 KAFKA-15265: Dynamic broker configs for remote fetch/copy
quotas (#16078)
add 79b9c44acdb KAFKA-10787 Apply spotless to connect module (#16299)
No new revisions were added by this update.
Summary of changes:
build.gradle | 8 ---
.../apache/kafka/connect/connector/Connector.java | 2 +-
.../java/org/apache/kafka/connect/data/Struct.java | 1 -
.../java/org/apache/kafka/connect/data/Values.java | 1 +
.../apache/kafka/connect/health/AbstractState.java | 4 +-
.../kafka/connect/health/ConnectorHealth.java | 4 +-
.../kafka/connect/sink/ErrantRecordReporter.java | 3 +-
.../connect/storage/SimpleHeaderConverter.java | 1 +
.../kafka/connect/connector/ConnectorTest.java | 6 +-
.../kafka/connect/data/ConnectSchemaTest.java | 1 +
.../org/apache/kafka/connect/data/DateTest.java | 1 +
.../kafka/connect/data/SchemaBuilderTest.java | 1 +
.../kafka/connect/data/SchemaProjectorTest.java | 1 +
.../org/apache/kafka/connect/data/TimeTest.java | 1 +
.../apache/kafka/connect/data/TimestampTest.java | 1 +
.../org/apache/kafka/connect/data/ValuesTest.java | 1 +
.../kafka/connect/header/ConnectHeaderTest.java | 1 +
.../kafka/connect/header/ConnectHeadersTest.java | 1 +
.../kafka/connect/sink/SinkConnectorTest.java | 6 +-
.../apache/kafka/connect/sink/SinkRecordTest.java | 1 +
.../kafka/connect/source/SourceConnectorTest.java | 6 +-
.../kafka/connect/source/SourceRecordTest.java | 1 +
.../connect/storage/SimpleHeaderConverterTest.java | 1 +
.../kafka/connect/storage/StringConverterTest.java | 1 +
.../extension/BasicAuthSecurityRestExtension.java | 4 +-
.../basic/auth/extension/JaasBasicAuthFilter.java | 20 +++---
.../auth/extension/PropertyFileLoginModule.java | 1 +
.../BasicAuthSecurityRestExtensionTest.java | 7 ++-
.../auth/extension/JaasBasicAuthFilterTest.java | 14 ++---
.../connect/file/FileStreamSinkConnector.java | 1 +
.../kafka/connect/file/FileStreamSinkTask.java | 1 +
.../connect/file/FileStreamSourceConnector.java | 1 +
.../kafka/connect/file/FileStreamSourceTask.java | 17 +++---
.../connect/file/FileStreamSinkConnectorTest.java | 9 +--
.../kafka/connect/file/FileStreamSinkTaskTest.java | 2 +
.../file/FileStreamSourceConnectorTest.java | 1 +
.../connect/file/FileStreamSourceTaskTest.java | 1 +
.../FileStreamSinkConnectorIntegrationTest.java | 1 +
.../FileStreamSourceConnectorIntegrationTest.java | 1 +
.../apache/kafka/connect/json/JsonConverter.java | 25 ++++----
.../kafka/connect/json/JsonConverterConfig.java | 2 +-
.../kafka/connect/json/JsonDeserializer.java | 5 +-
.../apache/kafka/connect/json/JsonSerializer.java | 5 +-
.../connect/json/JsonConverterConfigTest.java | 1 +
.../kafka/connect/json/JsonConverterTest.java | 12 ++--
.../apache/kafka/connect/mirror/Checkpoint.java | 9 ++-
.../connect/mirror/DefaultReplicationPolicy.java | 6 +-
.../org/apache/kafka/connect/mirror/Heartbeat.java | 7 +--
.../connect/mirror/IdentityReplicationPolicy.java | 4 +-
.../apache/kafka/connect/mirror/MirrorClient.java | 20 +++---
.../kafka/connect/mirror/MirrorClientConfig.java | 6 +-
.../kafka/connect/mirror/RemoteClusterUtils.java | 4 +-
.../kafka/connect/mirror/SourceAndTarget.java | 1 -
.../kafka/connect/mirror/MirrorClientTest.java | 10 +--
.../connect/mirror/ReplicationPolicyTest.java | 2 +-
.../kafka/connect/mirror/CheckpointStore.java | 1 +
.../kafka/connect/mirror/ConfigPropertyFilter.java | 1 +
.../mirror/DefaultConfigPropertyFilter.java | 2 +-
.../kafka/connect/mirror/DefaultGroupFilter.java | 2 +-
.../kafka/connect/mirror/DefaultTopicFilter.java | 2 +-
.../apache/kafka/connect/mirror/GroupFilter.java | 1 +
.../connect/mirror/MirrorCheckpointConnector.java | 1 +
.../connect/mirror/MirrorCheckpointMetrics.java | 14 ++---
.../kafka/connect/mirror/MirrorCheckpointTask.java | 24 ++++----
.../connect/mirror/MirrorCheckpointTaskConfig.java | 7 +--
.../connect/mirror/MirrorConnectorConfig.java | 15 ++---
.../connect/mirror/MirrorHeartbeatConnector.java | 10 +--
.../kafka/connect/mirror/MirrorHeartbeatTask.java | 10 +--
.../apache/kafka/connect/mirror/MirrorHerder.java | 1 +
.../apache/kafka/connect/mirror/MirrorMaker.java | 40 ++++++------
.../kafka/connect/mirror/MirrorMakerConfig.java | 23 ++++---
.../connect/mirror/MirrorSourceConnector.java | 71 +++++++++++-----------
.../kafka/connect/mirror/MirrorSourceTask.java | 28 ++++-----
.../connect/mirror/MirrorSourceTaskConfig.java | 6 +-
.../apache/kafka/connect/mirror/MirrorUtils.java | 11 ++--
.../apache/kafka/connect/mirror/OffsetSync.java | 3 +-
.../kafka/connect/mirror/OffsetSyncStore.java | 1 +
.../org/apache/kafka/connect/mirror/Scheduler.java | 13 ++--
.../apache/kafka/connect/mirror/TopicFilter.java | 1 +
.../mirror/formatters/CheckpointFormatter.java | 4 +-
.../mirror/formatters/HeartbeatFormatter.java | 4 +-
.../mirror/formatters/OffsetSyncFormatter.java | 4 +-
.../connect/mirror/rest/MirrorRestServer.java | 1 +
.../rest/resources/InternalMirrorResource.java | 3 +-
.../kafka/connect/mirror/CheckpointStoreTest.java | 5 +-
.../connect/mirror/MirrorCheckpointConfigTest.java | 1 +
.../mirror/MirrorCheckpointConnectorTest.java | 1 +
.../connect/mirror/MirrorCheckpointTaskTest.java | 15 +++--
.../connect/mirror/MirrorConnectorConfigTest.java | 7 ++-
.../mirror/MirrorHeartBeatConnectorTest.java | 17 +++---
.../connect/mirror/MirrorHeartbeatTaskTest.java | 1 +
.../connect/mirror/MirrorMakerConfigTest.java | 14 ++---
.../connect/mirror/MirrorSourceConfigTest.java | 1 +
.../connect/mirror/MirrorSourceConnectorTest.java | 46 +++++++-------
.../connect/mirror/MirrorSourceMetricsTest.java | 1 +
.../kafka/connect/mirror/MirrorSourceTaskTest.java | 11 ++--
.../kafka/connect/mirror/MirrorUtilsTest.java | 1 +
.../FakeForwardingAdminWithLocalMetadata.java | 1 +
.../clients/admin/FakeLocalMetadataStore.java | 1 +
.../DedicatedMirrorIntegrationTest.java | 1 +
.../IdentityReplicationIntegrationTest.java | 5 +-
.../MirrorConnectorsIntegrationBaseTest.java | 28 ++++-----
...MirrorConnectorsIntegrationExactlyOnceTest.java | 1 +
.../MirrorConnectorsIntegrationSSLTest.java | 9 ++-
...irrorConnectorsIntegrationTransactionsTest.java | 1 +
...rsWithCustomForwardingAdminIntegrationTest.java | 1 +
.../apache/kafka/connect/tools/MockConnector.java | 1 +
.../apache/kafka/connect/tools/MockSinkTask.java | 1 +
.../apache/kafka/connect/tools/MockSourceTask.java | 1 +
.../kafka/connect/tools/SchemaSourceTask.java | 1 +
.../kafka/connect/tools/VerifiableSinkTask.java | 5 +-
.../kafka/connect/tools/VerifiableSourceTask.java | 12 ++--
.../org/apache/kafka/connect/transforms/Cast.java | 1 +
.../kafka/connect/transforms/ExtractField.java | 2 +-
.../apache/kafka/connect/transforms/Filter.java | 4 +-
.../kafka/connect/transforms/InsertField.java | 2 +-
.../apache/kafka/connect/transforms/MaskField.java | 2 +-
.../kafka/connect/transforms/RegexRouter.java | 1 +
.../connect/transforms/SetSchemaMetadata.java | 1 +
.../transforms/predicates/HasHeaderKey.java | 6 +-
.../transforms/predicates/RecordIsTombstone.java | 4 +-
.../transforms/predicates/TopicNameMatches.java | 8 +--
.../apache/kafka/connect/transforms/CastTest.java | 1 +
.../kafka/connect/transforms/DropHeadersTest.java | 2 +-
.../kafka/connect/transforms/ExtractFieldTest.java | 3 +-
.../kafka/connect/transforms/FlattenTest.java | 1 +
.../kafka/connect/transforms/HeaderFromTest.java | 2 +-
.../kafka/connect/transforms/HoistFieldTest.java | 1 +
.../kafka/connect/transforms/InsertFieldTest.java | 1 +
.../kafka/connect/transforms/InsertHeaderTest.java | 2 +-
.../kafka/connect/transforms/MaskFieldTest.java | 1 +
.../kafka/connect/transforms/RegexRouterTest.java | 1 +
.../kafka/connect/transforms/ReplaceFieldTest.java | 1 +
.../connect/transforms/SetSchemaMetadataTest.java | 1 +
.../connect/transforms/TimestampConverterTest.java | 3 +-
.../connect/transforms/TimestampRouterTest.java | 1 +
.../kafka/connect/transforms/ValueToKeyTest.java | 1 +
.../transforms/field/FieldPathNotationTest.java | 1 +
.../transforms/field/FieldSyntaxVersionTest.java | 1 +
.../transforms/field/SingleFieldPathTest.java | 7 ++-
.../transforms/predicates/HasHeaderKeyTest.java | 1 +
.../predicates/TopicNameMatchesTest.java | 1 +
.../transforms/util/NonEmptyListValidatorTest.java | 1 +
143 files changed, 442 insertions(+), 372 deletions(-)
