You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/04/22 05:20:12 UTC
(pulsar) 04/04: [fix][broker] Fix typos in Consumer class (#22532)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit beb147c701728f9a2c0fcc9b56d4efb53f94a9bc
Author: hanmz <gu...@tencent.com>
AuthorDate: Fri Apr 19 06:49:18 2024 +0800
[fix][broker] Fix typos in Consumer class (#22532)
(cherry picked from commit 7aedb6b20c120ec0a7cc096e33e6305caca26786)
---
.../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 d8ed99bb874..a98fc86c03e 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
@@ -146,7 +146,7 @@ public class Consumer {
@Setter
private volatile long consumerEpoch;
- private long negtiveUnackedMsgsTimestamp;
+ private long negativeUnackedMsgsTimestamp;
@Getter
private final SchemaType schemaType;
@@ -1086,8 +1086,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;