Skip to content

Commit 7aedb6b

Browse files
authored
[fix][broker] Fix typos in Consumer class (apache#22532)
1 parent 7acbc4c commit 7aedb6b

File tree

1 file changed

+3
-3
lines changed
  • pulsar-broker/src/main/java/org/apache/pulsar/broker/service

1 file changed

+3
-3
lines changed

Diff for: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ public class Consumer {
147147
@Setter
148148
private volatile long consumerEpoch;
149149

150-
private long negtiveUnackedMsgsTimestamp;
150+
private long negativeUnackedMsgsTimestamp;
151151

152152
@Getter
153153
private final SchemaType schemaType;
@@ -1102,8 +1102,8 @@ private int addAndGetUnAckedMsgs(Consumer consumer, int ackedMessages) {
11021102
subscription.addUnAckedMessages(ackedMessages);
11031103
unackedMsgs = UNACKED_MESSAGES_UPDATER.addAndGet(consumer, ackedMessages);
11041104
}
1105-
if (unackedMsgs < 0 && System.currentTimeMillis() - negtiveUnackedMsgsTimestamp >= 10_000) {
1106-
negtiveUnackedMsgsTimestamp = System.currentTimeMillis();
1105+
if (unackedMsgs < 0 && System.currentTimeMillis() - negativeUnackedMsgsTimestamp >= 10_000) {
1106+
negativeUnackedMsgsTimestamp = System.currentTimeMillis();
11071107
log.warn("unackedMsgs is : {}, ackedMessages : {}, consumer : {}", unackedMsgs, ackedMessages, consumer);
11081108
}
11091109
return unackedMsgs;

0 commit comments

Comments
 (0)