[fix][broker] Fix if dynamicConfig item in ZK do not exist in broker …

…cause NPE (#17705)
apache · Sep 19, 2022 · 8bc02aa · 8bc02aa
1 parent 8b771a6
commit 8bc02aa
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -2152,7 +2152,12 @@ private void handleDynamicConfigurationUpdates() {
                         }
                         Map<String, String> data = optMap.get();
                         data.forEach((configKey, value) -> {
-                            Field configField = dynamicConfigurationMap.get(configKey).field;
+                            ConfigField configFieldWrapper = dynamicConfigurationMap.get(configKey);
+                            if (configFieldWrapper == null) {
+                                log.warn("{} does not exist in dynamicConfigurationMap, skip this config.", configKey);
+                                return;
+                            }
+                            Field configField = configFieldWrapper.field;
                             Object newValue = FieldParser.value(data.get(configKey), configField);
                             if (configField != null) {
                                 Consumer listener = configRegisteredListeners.get(configKey);