You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by kk...@apache.org on 2020/05/27 05:08:13 UTC
[kafka] branch trunk updated (4b97e50 -> 371f14c)
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 4b97e50 MINOR: Added doc for KIP-535 and updated it for KIP-562 (#8395)
add 371f14c KAFKA-5295: Allow source connectors to specify topic-specific settings for new topics (KIP-158) (#8722)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 48 +-
.../connect/runtime/SourceConnectorConfig.java | 152 ++++++-
.../kafka/connect/runtime/TopicCreationConfig.java | 142 ++++++
.../kafka/connect/runtime/TransformationChain.java | 3 +-
.../org/apache/kafka/connect/runtime/Worker.java | 69 +--
.../apache/kafka/connect/runtime/WorkerConfig.java | 19 +-
.../kafka/connect/runtime/WorkerSinkTask.java | 14 +-
.../kafka/connect/runtime/WorkerSourceTask.java | 119 +++--
.../runtime/distributed/DistributedConfig.java | 28 +-
.../runtime/distributed/DistributedHerder.java | 2 +-
.../runtime/standalone/StandaloneHerder.java | 2 +-
.../org/apache/kafka/connect/util/TopicAdmin.java | 72 ++-
.../apache/kafka/connect/util/TopicCreation.java | 148 ++++++
.../kafka/connect/util/TopicCreationGroup.java | 151 +++++++
.../integration/ConnectWorkerIntegrationTest.java | 94 ++--
.../ConnectorTopicsIntegrationTest.java | 5 +
.../integration/ExampleConnectIntegrationTest.java | 7 +-
.../RebalanceSourceConnectorsIntegrationTest.java | 63 +--
.../SourceConnectorsIntegrationTest.java | 233 ++++++++++
.../kafka/connect/runtime/AbstractHerderTest.java | 42 +-
.../kafka/connect/runtime/ConnectorConfigTest.java | 2 +-
.../connect/runtime/ErrorHandlingTaskTest.java | 61 ++-
...=> ErrorHandlingTaskWithTopicCreationTest.java} | 73 ++-
.../connect/runtime/SourceConnectorConfigTest.java | 150 +++++++
.../connect/runtime/WorkerSourceTaskTest.java | 131 ++++--
... => WorkerSourceTaskWithTopicCreationTest.java} | 496 +++++++++++++++++----
.../apache/kafka/connect/runtime/WorkerTest.java | 208 +++------
...rTest.java => WorkerWithTopicCreationTest.java} | 247 ++++------
.../runtime/standalone/StandaloneHerderTest.java | 17 +-
.../apache/kafka/connect/util/TopicAdminTest.java | 120 ++++-
.../kafka/connect/util/TopicCreationTest.java | 488 ++++++++++++++++++++
.../util/clusters/EmbeddedConnectCluster.java | 4 +-
.../clusters/EmbeddedConnectClusterAssertions.java | 15 +-
33 files changed, 2718 insertions(+), 707 deletions(-)
create mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicCreationConfig.java
create mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreation.java
create mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicCreationGroup.java
create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/integration/SourceConnectorsIntegrationTest.java
copy connect/runtime/src/test/java/org/apache/kafka/connect/runtime/{ErrorHandlingTaskTest.java => ErrorHandlingTaskWithTopicCreationTest.java} (87%)
create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SourceConnectorConfigTest.java
copy connect/runtime/src/test/java/org/apache/kafka/connect/runtime/{WorkerSourceTaskTest.java => WorkerSourceTaskWithTopicCreationTest.java} (67%)
copy connect/runtime/src/test/java/org/apache/kafka/connect/runtime/{WorkerTest.java => WorkerWithTopicCreationTest.java} (88%)
create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicCreationTest.java