You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by ce...@apache.org on 2024/06/10 21:02:14 UTC

(kafka) branch trunk updated (1426e8e9206 -> eec8fd6a98c)

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

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


    from 1426e8e9206 KAFKA-16764: New consumer should throw InvalidTopicException on poll when invalid topic in metadata. (#16043)
     add eec8fd6a98c KAFKA-9228: Restart tasks on runtime-only connector config changes (#16053)

No new revisions were added by this update.

Summary of changes:
 .../kafka/connect/runtime/AbstractHerder.java      |  11 +-
 .../connect/storage/AppliedConnectorConfig.java    |  66 ++++++++++
 .../kafka/connect/storage/ClusterConfigState.java  |  20 +++
 .../connect/storage/KafkaConfigBackingStore.java   |  12 +-
 .../connect/storage/MemoryConfigBackingStore.java  |  18 +++
 .../integration/ConnectWorkerIntegrationTest.java  | 135 +++++++++++++++++++++
 .../kafka/connect/runtime/AbstractHerderTest.java  |  41 +++++++
 .../apache/kafka/connect/runtime/WorkerTest.java   |   5 +
 .../kafka/connect/runtime/WorkerTestUtils.java     |  10 +-
 .../runtime/distributed/DistributedHerderTest.java |  26 ++++
 .../IncrementalCooperativeAssignorTest.java        |   7 ++
 .../runtime/distributed/WorkerCoordinatorTest.java |  10 ++
 .../runtime/standalone/StandaloneHerderTest.java   |  26 +++-
 .../org.apache.kafka.connect.sink.SinkConnector    |   3 +-
 14 files changed, 383 insertions(+), 7 deletions(-)
 create mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/storage/AppliedConnectorConfig.java