This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 5e820571de1 MINOR: Fix base ConfigDef in
AbstractHerder::connectorPluginConfig (#13466)
5e820571de1 is described below
commit 5e820571de11d7157262c8bc6bbb59402a700ca5
Author: Chris Egerton <[email protected]>
AuthorDate: Tue Apr 4 02:57:42 2023 -0700
MINOR: Fix base ConfigDef in AbstractHerder::connectorPluginConfig (#13466)
Reviewers: Mickael Maison <[email protected]>, Greg Harris
<[email protected]>
---
.../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 62e5011ca6e..125b93dab73 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
@@ -842,7 +842,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:
