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:30:12 UTC
[kafka] branch 3.3 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.3
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.3 by this push:
new f50020f3f3c MINOR: Fix base ConfigDef in AbstractHerder::connectorPluginConfig (#13466)
f50020f3f3c is described below
commit f50020f3f3c519f9c9b2321882aa0ff1fd4d9413
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 879aabe06c3..02e4b8950a7 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
@@ -806,7 +806,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: