(kafka) branch 3.6 updated: KAFKA-16428: Fix bug where config change notification znode may not get created during migration (#15608)

[cm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cmccabe pushed a commit to branch 3.6
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/3.6 by this push:
     new 7303b6063bc KAFKA-16428: Fix bug where config change notification znode may not get created during migration (#15608)
7303b6063bc is described below

commit 7303b6063bc16a4bc8a75083a55460be08c5c9c0
Author: Colin Patrick McCabe <cm...@apache.org>
AuthorDate: Wed Mar 27 12:26:36 2024 -0700

    KAFKA-16428: Fix bug where config change notification znode may not get created during migration (#15608)
    
    Reviewers: Chia-Ping Tsai <ch...@gmail.com>, Luke Chen <sh...@gmail.com>
---
 core/src/main/scala/kafka/zk/migration/ZkConfigMigrationClient.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/zk/migration/ZkConfigMigrationClient.scala b/core/src/main/scala/kafka/zk/migration/ZkConfigMigrationClient.scala
index 844c1aabc4c..fbf6d7c3434 100644
--- a/core/src/main/scala/kafka/zk/migration/ZkConfigMigrationClient.scala
+++ b/core/src/main/scala/kafka/zk/migration/ZkConfigMigrationClient.scala
@@ -244,7 +244,7 @@ class ZkConfigMigrationClient(
         state
       } else if (responses.head.resultCode.equals(Code.OK)) {
         // Write the notification znode if our update was successful
-        zkClient.createConfigChangeNotification(s"$configType/$configName")
+        zkClient.createConfigChangeNotification(s"${configType.get}/$configName")
         state.withMigrationZkVersion(migrationZkVersion)
       } else {
         throw KeeperException.create(responses.head.resultCode, path)