poorbarcode commented on code in PR #19972:
URL: https://github.com/apache/pulsar/pull/19972#discussion_r1156789638
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java:
##
@@ -1696,14 +1696,32 @@ public void openCursorFailed(ManagedLed
poorbarcode commented on code in PR #19972:
URL: https://github.com/apache/pulsar/pull/19972#discussion_r1155093515
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java:
##
@@ -1696,14 +1696,31 @@ public void openCursorFailed(ManagedLed
poorbarcode commented on code in PR #19972:
URL: https://github.com/apache/pulsar/pull/19972#discussion_r1154121495
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java:
##
@@ -338,7 +338,38 @@ public CompletableFuture initialize() {
poorbarcode commented on code in PR #19972:
URL: https://github.com/apache/pulsar/pull/19972#discussion_r1154072079
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java:
##
@@ -338,7 +338,38 @@ public CompletableFuture initialize() {
poorbarcode commented on code in PR #19972:
URL: https://github.com/apache/pulsar/pull/19972#discussion_r1154048927
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java:
##
@@ -338,7 +338,38 @@ public CompletableFuture initialize() {
poorbarcode commented on code in PR #19972:
URL: https://github.com/apache/pulsar/pull/19972#discussion_r1153979225
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java:
##
@@ -338,7 +338,38 @@ public CompletableFuture initialize() {