lhotari commented on code in PR #25070:
URL: https://github.com/apache/pulsar/pull/25070#discussion_r2662262849
##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicListService.java:
##########
@@ -50,15 +68,21 @@ public static class TopicListWatcher implements
BiConsumer<String, NotificationT
private final long id;
/** The regexp for the topic name(not contains partition suffix). **/
private final TopicsPattern topicsPattern;
+ private final Executor executor;
+ private volatile boolean closed = false;
+ private boolean sendTopicListSuccessCompleted = false;
+ private BlockingDeque<Runnable> sendTopicListUpdateTasksBeforeInit =
new LinkedBlockingDeque<>();
Review Comment:
This has been addressed by setting an upper bound for the buffer.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
