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) {