You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2023/04/04 10:16:50 UTC
[kafka] branch 3.4 updated: MINOR: Fix base ConfigDef in AbstractHerder::connectorPluginConfig (#13466)
This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a commit to branch 3.4
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.4 by this push:
new 699c3511a7a MINOR: Fix base ConfigDef in AbstractHerder::connectorPluginConfig (#13466)
699c3511a7a is described below
commit 699c3511a7a230dc450b0f5f27e67785fa1c7983
Author: Chris Egerton <ch...@aiven.io>
AuthorDate: Tue Apr 4 02:57:42 2023 -0700
MINOR: Fix base ConfigDef in AbstractHerder::connectorPluginConfig (#13466)
Reviewers: Mickael Maison <mi...@gmail.com>, Greg Harris <gh...@gmail.com>
---
.../src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java
index 5f3c1a23bb5..51eaaceb86b 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java
@@ -812,7 +812,7 @@ public abstract class AbstractHerder implements Herder, TaskStatus.Listener, Con
ConfigDef pluginConfigDefs;
switch (pluginType) {
case SINK:
- baseConfigDefs = SourceConnectorConfig.configDef();
+ baseConfigDefs = SinkConnectorConfig.configDef();
pluginConfigDefs = ((SinkConnector) plugin).config();
break;
case SOURCE: