[pulsar] branch master updated: Fixed response when closing topic list watcher (#16529)

[mmerli]

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

mmerli 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 de343c89801 Fixed response when closing topic list watcher (#16529)
de343c89801 is described below

commit de343c898018d32068e0446fd55f6080a1abd395
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Tue Jul 12 16:13:18 2022 -0700

    Fixed response when closing topic list watcher (#16529)
---
 .../main/java/org/apache/pulsar/broker/service/TopicListService.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicListService.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicListService.java
index 78ee45223eb..966e6d0fa30 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicListService.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicListService.java
@@ -207,7 +207,7 @@ public class TopicListService {
         long requestId = commandWatchTopicListClose.getRequestId();
         long watcherId = commandWatchTopicListClose.getWatcherId();
         deleteTopicListWatcher(watcherId);
-        connection.getCommandSender().sendWatchTopicListSuccess(requestId, 
watcherId, null, null);
+        connection.getCommandSender().sendSuccess(requestId);
     }
 
     public void deleteTopicListWatcher(Long watcherId) {