Skip to content

Commit

Permalink
Update pulsar-broker/src/main/java/org/apache/pulsar/broker/service/p…
Browse files Browse the repository at this point in the history
…ersistent/PersistentTopic.java

Co-authored-by: Lari Hotari <[email protected]>
  • Loading branch information
daziz and lhotari authored Dec 27, 2024
1 parent 6eeb566 commit c08a699
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -3140,7 +3140,7 @@ public void checkGC() {
* "replicator.producer" to a null value.
* Race condition: task 1 will get a NPE when it tries to send messages using the variable
* "replicator.producer", because task 2 will set this variable to "null".
* TODO Create a separated PR to fix it.
* TODO Create a separate PR to fix it.
*/
closeReplProducersIfNoBacklog().thenRun(() -> {
if (hasRemoteProducers()) {
Expand Down

0 comments on commit c08a699

Please sign in to comment.