(pulsar) branch master updated: [cleanup][broker] cleanup deprecated method of metadata store etcd (#21253)

[technoboy]

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

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 2e31e71098d [cleanup][broker] cleanup deprecated method of metadata 
store etcd (#21253)
2e31e71098d is described below

commit 2e31e71098d63dfe111b225d8f8219ea05d1951f
Author: Lan <gcs...@gmail.com>
AuthorDate: Fri Dec 8 22:32:52 2023 +0800

    [cleanup][broker] cleanup deprecated method of metadata store etcd (#21253)
    
    Signed-off-by: Lan Liang <gcs...@gmail.com>
---
 .../java/org/apache/pulsar/metadata/impl/EtcdMetadataStore.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/EtcdMetadataStore.java
 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/EtcdMetadataStore.java
index a7fb7192cb5..194b0d6a2f8 100644
--- 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/EtcdMetadataStore.java
+++ 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/EtcdMetadataStore.java
@@ -109,9 +109,9 @@ public class EtcdMetadataStore extends 
AbstractBatchedMetadataStore {
         try {
             this.client = newEtcdClient(metadataURL, conf);
             this.kv = client.getKVClient();
-            this.client.getWatchClient().watch(ByteSequence.from("\0", 
StandardCharsets.UTF_8),
+            this.client.getWatchClient().watch(ByteSequence.from("/", 
StandardCharsets.UTF_8),
                     WatchOption.newBuilder()
-                            .withPrefix(ByteSequence.from("/", 
StandardCharsets.UTF_8))
+                            .isPrefix(true)
                             .build(), this::handleWatchResponse);
             if (enableSessionWatcher) {
                 this.sessionWatcher =
@@ -285,7 +285,7 @@ public class EtcdMetadataStore extends 
AbstractBatchedMetadataStore {
                                 .withKeysOnly(true)
                                 .withSortField(GetOption.SortTarget.KEY)
                                 .withSortOrder(GetOption.SortOrder.ASCEND)
-                                .withPrefix(prefix)
+                                .isPrefix(true)
                                 .build()));
                         break;
                     }