From 5b33be21c5cb0cb3a8909dba77a281947fecd17b Mon Sep 17 00:00:00 2001 From: Chris Egerton Date: Tue, 5 Sep 2023 16:27:31 -0400 Subject: [PATCH] Change 'transformation' to 'pluginInstance' in EnrichablePlugin::getConfigDefFromConfigProvidingClass --- .../org/apache/kafka/connect/runtime/ConnectorConfig.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java index f33f00e40efa..6d7f698258d3 100644 --- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java +++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java @@ -510,13 +510,13 @@ ConfigDef getConfigDefFromConfigProvidingClass(String key, Class cls) { } Utils.ensureConcreteSubclass(baseClass, cls); - T transformation; + T pluginInstance; try { - transformation = Utils.newInstance(cls, baseClass); + pluginInstance = Utils.newInstance(cls, baseClass); } catch (Exception e) { throw new ConfigException(key, String.valueOf(cls), "Error getting config definition from " + baseClass.getSimpleName() + ": " + e.getMessage()); } - ConfigDef configDef = config(transformation); + ConfigDef configDef = config(pluginInstance); if (null == configDef) { throw new ConnectException( String.format(