Fixed response when closing topic list watcher (#16529)

apache · Jul 12, 2022 · de343c8 · de343c8
1 parent 09f4333
commit de343c8
Showing 1 changed file with 1 addition and 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
@@ -207,7 +207,7 @@ public void handleWatchTopicListClose(CommandWatchTopicListClose commandWatchTop
         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) {