[kafka] branch trunk updated (b78fa9c -> 07843cf)

[kk...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kkarantasis pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from b78fa9c  KAFKA-10833: Expose task configurations in Connect REST API (KIP-661) (#9726)
     add 07843cf  KAFKA-10834: Remove redundant type casts in Connect (#10053)

No new revisions were added by this update.

Summary of changes:
 .../policy/ConnectorClientConfigRequest.java       |   2 +-
 .../connector/ConnectorReconfigurationTest.java    |   2 +-
 .../org/apache/kafka/connect/data/ValuesTest.java  |   8 +-
 .../apache/kafka/connect/mirror/Checkpoint.java    |   2 +-
 .../org/apache/kafka/connect/mirror/Heartbeat.java |   2 +-
 .../apache/kafka/connect/mirror/MirrorMaker.java   |   2 +-
 .../MirrorConnectorsIntegrationBaseTest.java       |  12 +-
 .../MirrorConnectorsIntegrationSSLTest.java        |   4 +-
 .../kafka/connect/cli/ConnectStandalone.java       |   2 +-
 ...bstractConnectorClientConfigOverridePolicy.java |   2 +-
 .../connect/runtime/ConnectMetricsRegistry.java    |   2 +-
 .../connect/runtime/SourceTaskOffsetCommitter.java |   2 +-
 .../apache/kafka/connect/runtime/WorkerConfig.java |   2 +-
 .../runtime/distributed/DistributedHerder.java     |   6 +-
 .../kafka/connect/runtime/rest/RestClient.java     |   2 +-
 .../runtime/rest/resources/ConnectorsResource.java |   4 +-
 .../runtime/standalone/StandaloneHerder.java       |   2 +-
 .../connect/storage/MemoryConfigBackingStore.java  |   2 +-
 .../org/apache/kafka/connect/util/TopicAdmin.java  |   2 +-
 .../integration/TransformationIntegrationTest.java |   4 +-
 .../kafka/connect/runtime/AbstractHerderTest.java  |  10 +-
 .../kafka/connect/runtime/ConnectMetricsTest.java  |   2 +-
 .../kafka/connect/runtime/ConnectorConfigTest.java |   2 +-
 .../kafka/connect/runtime/MockConnectMetrics.java  |   4 +-
 .../kafka/connect/runtime/WorkerSinkTaskTest.java  |  60 ++++----
 .../runtime/WorkerSinkTaskThreadedTest.java        |   2 +-
 .../apache/kafka/connect/runtime/WorkerTest.java   |  14 +-
 .../runtime/WorkerWithTopicCreationTest.java       |  12 +-
 .../runtime/distributed/DistributedHerderTest.java | 167 ++++++++++-----------
 .../runtime/distributed/WorkerCoordinatorTest.java |  44 +++---
 .../resources/ConnectorPluginsResourceTest.java    |  20 +--
 .../rest/resources/ConnectorsResourceTest.java     |  10 +-
 .../runtime/standalone/StandaloneHerderTest.java   |  13 +-
 .../storage/FileOffsetBackingStoreTest.java        |   2 +-
 .../storage/KafkaConfigBackingStoreTest.java       |   8 +-
 .../storage/KafkaOffsetBackingStoreTest.java       |   4 +-
 .../connect/storage/OffsetStorageWriterTest.java   |   2 +-
 .../apache/kafka/connect/util/TopicAdminTest.java  |  21 ++-
 .../kafka/connect/transforms/FlattenTest.java      |   6 +-
 .../connect/transforms/SetSchemaMetadataTest.java  |   2 +-
 .../connect/transforms/TimestampRouterTest.java    |   2 +-
 41 files changed, 233 insertions(+), 240 deletions(-)