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 <[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 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:
