Skip to content

Commit 44ecfdb

Browse files
committed
Fix NPE in transform method
1 parent 6ef4001 commit 44ecfdb

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -624,6 +624,7 @@ private Map<String, Plugin<ConfigProvider>> instantiateConfigProviders(
624624
Map<String, Plugin<ConfigProvider>> configProviderPluginInstances = new HashMap<>();
625625
for (Map.Entry<String, String> entry : providerMap.entrySet()) {
626626
try {
627+
System.out.println("Checking:" + entry);
627628
String prefix = CONFIG_PROVIDERS_CONFIG + "." + entry.getKey() + CONFIG_PROVIDERS_PARAM;
628629
Map<String, ?> configProperties = configProviderProperties(prefix, providerConfigProperties);
629630
ConfigProvider provider = Utils.newInstance(entry.getValue(), ConfigProvider.class);

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -96,13 +96,13 @@ public ConfigTransformerResult transform(Map<String, String> configs) {
9696
Map<String, Long> ttls = new HashMap<>();
9797
for (Map.Entry<String, Map<String, Set<String>>> entry : keysByProvider.entrySet()) {
9898
String providerName = entry.getKey();
99-
ConfigProvider provider = configProviderPlugins.get(providerName).get();
99+
Plugin<ConfigProvider> providerPlugin = configProviderPlugins.get(providerName);
100100
Map<String, Set<String>> keysByPath = entry.getValue();
101-
if (provider != null && keysByPath != null) {
101+
if (providerPlugin != null && keysByPath != null) {
102102
for (Map.Entry<String, Set<String>> pathWithKeys : keysByPath.entrySet()) {
103103
String path = pathWithKeys.getKey();
104104
Set<String> keys = new HashSet<>(pathWithKeys.getValue());
105-
ConfigData configData = provider.get(path, keys);
105+
ConfigData configData = providerPlugin.get().get(path, keys);
106106
Map<String, String> data = configData.data();
107107
Long ttl = configData.ttl();
108108
if (ttl != null && ttl >= 0) {

0 commit comments

Comments
 (0)