(pulsar) branch master updated: [fix][broker] Fix typos in Consumer class (#22532)

[daojun]

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

daojun 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 7aedb6b20c1 [fix][broker] Fix typos in Consumer class (#22532)
7aedb6b20c1 is described below

commit 7aedb6b20c120ec0a7cc096e33e6305caca26786
Author: hanmz <gunn...@tencent.com>
AuthorDate: Fri Apr 19 06:49:18 2024 +0800

    [fix][broker] Fix typos in Consumer class (#22532)
---
 .../src/main/java/org/apache/pulsar/broker/service/Consumer.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
index 4cd54420200..6b2028095e2 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java
@@ -147,7 +147,7 @@ public class Consumer {
     @Setter
     private volatile long consumerEpoch;
 
-    private long negtiveUnackedMsgsTimestamp;
+    private long negativeUnackedMsgsTimestamp;
 
     @Getter
     private final SchemaType schemaType;
@@ -1102,8 +1102,8 @@ public class Consumer {
             subscription.addUnAckedMessages(ackedMessages);
             unackedMsgs = UNACKED_MESSAGES_UPDATER.addAndGet(consumer, 
ackedMessages);
         }
-        if (unackedMsgs < 0 && System.currentTimeMillis() - 
negtiveUnackedMsgsTimestamp >= 10_000) {
-            negtiveUnackedMsgsTimestamp = System.currentTimeMillis();
+        if (unackedMsgs < 0 && System.currentTimeMillis() - 
negativeUnackedMsgsTimestamp >= 10_000) {
+            negativeUnackedMsgsTimestamp = System.currentTimeMillis();
             log.warn("unackedMsgs is : {}, ackedMessages : {}, consumer : {}", 
unackedMsgs, ackedMessages, consumer);
         }
         return unackedMsgs;