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 <chr...@aiven.io> AuthorDate: Tue Apr 4 02:57:42 2023 -0700 MINOR: Fix base ConfigDef in AbstractHerder::connectorPluginConfig (#13466) Reviewers: Mickael Maison <mickael.mai...@gmail.com>, Greg Harris <gharris1...@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: