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
