Skip to content

Commit 9e221e3

Browse files
committed
Update msg in Utils.closeQuietly
1 parent 08dff59 commit 9e221e3

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -556,7 +556,7 @@ private Map<String, String> extractPotentialVariables(Map<?, ?> configMap) {
556556
resolvedOriginals.putAll(result.data());
557557
}
558558
}
559-
providerPlugins.values().forEach(x -> Utils.closeQuietly(x, "config provider"));
559+
providerPlugins.values().forEach(x -> Utils.closeQuietly(x, "config provider plugin"));
560560

561561
return new ResolvingMap<>(resolvedOriginals, originals);
562562
}

connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -282,7 +282,7 @@ Map<String, String> transform(Map<String, String> props) {
282282
}
283283
ConfigTransformer transformer = new ConfigTransformer(providerPlugins);
284284
Map<String, String> transformed = transformer.transform(props).data();
285-
providerPlugins.values().forEach(x -> Utils.closeQuietly(x, "config provider"));
285+
providerPlugins.values().forEach(x -> Utils.closeQuietly(x, "config provider plugin"));
286286
return transformed;
287287
}
288288

connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfigTransformer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,6 @@ private void scheduleReload(String connectorName, String path, long ttl) {
9898

9999
@Override
100100
public void close() {
101-
configProviderPlugins.values().forEach(x -> Utils.closeQuietly(x, "config provider"));
101+
configProviderPlugins.values().forEach(x -> Utils.closeQuietly(x, "config provider plugin"));
102102
}
103103
}

0 commit comments

Comments
 (0)