[kafka] branch trunk updated (b20e2539b4e -> 8f00782be79)

[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 b20e2539b4e MINOR: Remove unnecessary call to asCollection causing eager dependency resolution (#13149)
     add 8f00782be79 MINOR: Connect Javadocs improvements (#13120)

No new revisions were added by this update.

Summary of changes:
 .../kafka/connect/connector/ConnectRecord.java     |  2 +-
 .../apache/kafka/connect/connector/Connector.java  | 10 +--
 .../kafka/connect/connector/ConnectorContext.java  |  2 +-
 .../org/apache/kafka/connect/connector/Task.java   |  2 +-
 .../ConnectorClientConfigOverridePolicy.java       | 20 +++---
 .../policy/ConnectorClientConfigRequest.java       | 43 +++++++-----
 .../apache/kafka/connect/data/ConnectSchema.java   | 10 +--
 .../java/org/apache/kafka/connect/data/Date.java   |  9 ++-
 .../org/apache/kafka/connect/data/Decimal.java     |  7 +-
 .../java/org/apache/kafka/connect/data/Schema.java | 26 +++++---
 .../apache/kafka/connect/data/SchemaAndValue.java  |  3 +
 .../apache/kafka/connect/data/SchemaBuilder.java   |  6 +-
 .../apache/kafka/connect/data/SchemaProjector.java |  4 +-
 .../java/org/apache/kafka/connect/data/Struct.java |  4 +-
 .../java/org/apache/kafka/connect/data/Time.java   |  9 ++-
 .../org/apache/kafka/connect/data/Timestamp.java   |  9 ++-
 .../java/org/apache/kafka/connect/data/Values.java | 22 +++----
 .../connect/errors/SchemaBuilderException.java     |  3 +
 .../connect/errors/SchemaProjectorException.java   |  3 +
 .../apache/kafka/connect/health/AbstractState.java | 10 +--
 .../kafka/connect/rest/ConnectRestExtension.java   |  4 +-
 .../connect/rest/ConnectRestExtensionContext.java  |  4 +-
 .../kafka/connect/sink/ErrantRecordReporter.java   | 10 +--
 .../org/apache/kafka/connect/sink/SinkRecord.java  |  4 +-
 .../org/apache/kafka/connect/sink/SinkTask.java    | 25 +++----
 .../apache/kafka/connect/sink/SinkTaskContext.java | 22 +++----
 .../apache/kafka/connect/source/SourceRecord.java  |  4 +-
 .../apache/kafka/connect/source/SourceTask.java    |  2 +-
 .../kafka/connect/source/SourceTaskContext.java    |  4 +-
 .../apache/kafka/connect/storage/Converter.java    |  6 +-
 .../kafka/connect/storage/HeaderConverter.java     |  5 ++
 .../kafka/connect/storage/StringConverter.java     |  6 +-
 .../kafka/connect/transforms/Transformation.java   | 17 +++--
 .../apache/kafka/connect/json/JsonConverter.java   | 18 ++---
 .../kafka/connect/json/JsonDeserializer.java       |  4 +-
 .../apache/kafka/connect/json/JsonSerializer.java  |  4 +-
 .../connect/mirror/IdentityReplicationPolicy.java  |  8 +--
 .../kafka/connect/mirror/RemoteClusterUtils.java   |  4 +-
 .../kafka/connect/mirror/ReplicationPolicy.java    |  4 +-
 .../connect/mirror/MirrorConnectorConfig.java      |  2 +-
 .../kafka/connect/mirror/MirrorMakerConfig.java    |  5 +-
 .../connect/converters/ByteArrayConverter.java     |  4 +-
 .../kafka/connect/converters/DoubleConverter.java  |  2 +-
 .../kafka/connect/converters/FloatConverter.java   |  2 +-
 .../kafka/connect/converters/IntegerConverter.java |  2 +-
 .../kafka/connect/converters/LongConverter.java    |  2 +-
 .../kafka/connect/converters/NumberConverter.java  |  2 +-
 .../kafka/connect/converters/ShortConverter.java   |  2 +-
 .../kafka/connect/runtime/AbstractHerder.java      | 10 ++-
 .../kafka/connect/runtime/ConnectMetrics.java      |  2 +-
 .../kafka/connect/runtime/ConnectorStatus.java     |  2 +-
 .../runtime/ExactlyOnceWorkerSourceTask.java       |  2 +-
 .../org/apache/kafka/connect/runtime/Herder.java   | 23 +++----
 .../connect/runtime/PredicatedTransformation.java  |  4 +-
 .../kafka/connect/runtime/RestartRequest.java      |  3 +-
 .../kafka/connect/runtime/SinkConnectorConfig.java |  2 +-
 .../connect/runtime/SourceTaskOffsetCommitter.java |  3 +-
 .../apache/kafka/connect/runtime/TargetState.java  |  2 +-
 .../kafka/connect/runtime/TopicCreationConfig.java |  5 ++
 .../kafka/connect/runtime/TransformationChain.java |  4 ++
 .../kafka/connect/runtime/WorkerConnector.java     |  2 +-
 .../kafka/connect/runtime/WorkerSinkTask.java      |  2 +-
 .../kafka/connect/runtime/WorkerSourceTask.java    |  2 +-
 .../apache/kafka/connect/runtime/WorkerTask.java   |  4 +-
 .../runtime/distributed/ConnectProtocol.java       |  8 +--
 .../distributed/ConnectProtocolCompatibility.java  |  6 +-
 .../runtime/distributed/DistributedConfig.java     |  3 +
 .../runtime/distributed/DistributedHerder.java     | 18 +++--
 .../connect/runtime/distributed/EagerAssignor.java |  2 +-
 .../runtime/distributed/ExtendedAssignment.java    |  2 +-
 .../IncrementalCooperativeConnectProtocol.java     |  4 +-
 .../distributed/RebalanceNeededException.java      |  3 +
 .../runtime/distributed/WorkerCoordinator.java     |  2 +-
 .../runtime/distributed/WorkerGroupMember.java     |  2 +-
 .../apache/kafka/connect/runtime/errors/Stage.java | 18 +++--
 .../kafka/connect/runtime/rest/RestClient.java     |  6 +-
 .../kafka/connect/runtime/rest/RestServer.java     |  8 +--
 .../rest/errors/ConnectExceptionMapper.java        |  3 +
 .../runtime/rest/resources/LoggingResource.java    |  4 +-
 .../kafka/connect/runtime/rest/util/SSLUtils.java  |  6 +-
 .../runtime/standalone/StandaloneConfig.java       |  3 +
 .../kafka/connect/storage/ClusterConfigState.java  | 14 ++--
 .../kafka/connect/storage/ConfigBackingStore.java  |  8 ++-
 .../connect/storage/KafkaConfigBackingStore.java   | 77 +++++++++++-----------
 .../connect/storage/KafkaStatusBackingStore.java   | 22 +++----
 .../connect/storage/MemoryConfigBackingStore.java  |  4 ++
 .../connect/storage/MemoryStatusBackingStore.java  |  3 +
 .../connect/storage/OffsetStorageReaderImpl.java   |  2 +-
 .../kafka/connect/storage/OffsetStorageWriter.java |  8 +--
 .../kafka/connect/storage/StatusBackingStore.java  |  3 +
 .../apache/kafka/connect/tools/MockConnector.java  |  2 +-
 .../kafka/connect/tools/SchemaSourceConnector.java |  4 ++
 .../kafka/connect/tools/VerifiableSourceTask.java  |  2 +-
 .../apache/kafka/connect/util/ConnectUtils.java    | 17 +++++
 .../connect/util/ConvertingFutureCallback.java     |  8 +++
 .../apache/kafka/connect/util/FutureCallback.java  |  4 ++
 .../apache/kafka/connect/util/KafkaBasedLog.java   |  6 +-
 .../apache/kafka/connect/util/LoggingContext.java  |  4 +-
 .../apache/kafka/connect/util/TopicCreation.java   |  6 +-
 .../kafka/connect/util/TopicCreationGroup.java     | 14 ++--
 100 files changed, 454 insertions(+), 306 deletions(-)