This is an automated email from the ASF dual-hosted git repository.

lhotari 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 b162d469069 [cleanup][broker] remove useless code comment (#22459)
b162d469069 is described below

commit b162d46906961623db09c97df3f06b7876cddb5e
Author: thetumbled <[email protected]>
AuthorDate: Tue Apr 9 13:14:25 2024 +0800

    [cleanup][broker] remove useless code comment (#22459)
---
 .../org/apache/pulsar/broker/service/persistent/PersistentTopic.java   | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index 1650e449a3f..b21cd165402 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -3875,9 +3875,6 @@ public class PersistentTopic extends AbstractTopic 
implements Topic, AddEntryCal
     @Override
     public void publishTxnMessage(TxnID txnID, ByteBuf headersAndPayload, 
PublishContext publishContext) {
         pendingWriteOps.incrementAndGet();
-        // in order to avoid the opAddEntry retain
-
-        // in order to promise the publish txn message orderly, we should 
change the transactionCompletableFuture
 
         if (isFenced) {
             publishContext.completed(new TopicFencedException("fenced"), -1, 
-1);

Reply via email to