(pulsar) branch master updated: [fix][broker] Fix typo (#21843)

[technoboy]

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

technoboy 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 e52cc35ae68 [fix][broker] Fix typo (#21843)
e52cc35ae68 is described below

commit e52cc35ae68d4eb80a1aae91a1c92b98d28951ca
Author: cyhone <cyh...@qq.com>
AuthorDate: Thu Jan 4 10:34:14 2024 +0800

    [fix][broker] Fix typo (#21843)
---
 .../apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
index 139507ba102..a59190ea6fc 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java
@@ -197,7 +197,7 @@ public class NonPersistentTopic extends AbstractTopic 
implements Topic, TopicPol
         subscriptions.forEach((name, subscription) -> {
             ByteBuf duplicateBuffer = data.retainedDuplicate();
             Entry entry = create(0L, 0L, duplicateBuffer);
-            // entry internally retains data so, duplicateBuffer should be 
release here
+            // entry internally retains data so, duplicateBuffer should be 
released here
             duplicateBuffer.release();
             if (subscription.getDispatcher() != null) {
                 // Dispatcher needs to call the set method to support entry 
filter feature.