Skip to content

Commit 96fd5a6

Browse files
committed
Refactor
1 parent 204c8a9 commit 96fd5a6

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2906,8 +2906,6 @@ public void testMonitorableConfigProvider() {
29062906
setup(false);
29072907
Map<String, String> props = new HashMap<>(this.workerProps);
29082908
props.put("config.providers", "monitorable,monitorable2");
2909-
props.put("config.providers.monitorable.class", MonitorableConfigProvider.class.getName());
2910-
props.put("config.providers.monitorable2.class", MonitorableConfigProvider.class.getName());
29112909
config = new StandaloneConfig(props);
29122910
mockKafkaClusterId();
29132911
when(plugins.newConfigProvider(any(AbstractConfig.class), any(String.class), any(ClassLoaderUsage.class), any(Metrics.class)))

connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginsTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -405,7 +405,7 @@ public void newConfigProviderShouldConfigureWithPluginClassLoader() {
405405
public void newConfigProviderShouldCallWithPluginMetricsAfterConfigure() {
406406
String providerName = "monitorable";
407407
String providerPrefix = WorkerConfig.CONFIG_PROVIDERS_CONFIG + "." + providerName;
408-
props.put(providerPrefix + ".class", CustomMonitorableConfigProvider .class.getName());
408+
props.put(providerPrefix + ".class", CustomMonitorableConfigProvider.class.getName());
409409
createConfig();
410410
Plugin<ConfigProvider> plugin = plugins.newConfigProvider(config, providerName, ClassLoaderUsage.PLUGINS, new Metrics());
411411
assertInstanceOf(CustomMonitorableConfigProvider.class, plugin.get());

0 commit comments

Comments
 (0)