fix some fail test

apache · Jan 23, 2025 · 28931c3 · 28931c3
1 parent 409be64
commit 28931c3
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/core/src/main/scala/kafka/server/metadata/DynamicConfigPublisher.scala b/core/src/main/scala/kafka/server/metadata/DynamicConfigPublisher.scala
@@ -72,7 +72,16 @@ class DynamicConfigPublisher(
               )
             case BROKER =>
               dynamicConfigHandlers.get(ConfigType.BROKER).foreach(nodeConfigHandler =>
-                if (resource.name() == conf.nodeId.toString) {
+                if (resource.name().isEmpty) {
+                  try {
+                    info("Updating cluster configuration : " + toLoggableProps(resource, props).mkString(","))
+                    nodeConfigHandler.processConfigChanges("", props)
+                  } catch {
+                    case t: Throwable => faultHandler.handleFault("Error updating " +
+                      s"cluster with new configuration: ${toLoggableProps(resource, props).mkString(",")} " +
+                      s"in $deltaName", t)
+                  }
+                } else if (resource.name() == conf.nodeId.toString) {
                   try {
                     // Apply changes to this node's dynamic configuration.
                     info(s"Updating node ${conf.nodeId} with new configuration : " +