You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/08/04 13:02:12 UTC
[pulsar] 03/09: Improve error logs in BacklogQuotaManager (#11469)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d34a91ac9be27a0f388c78a2e9efb7a1297e33d4
Author: Masahiro Sakamoto <ma...@yahoo-corp.jp>
AuthorDate: Tue Aug 3 01:22:38 2021 +0900
Improve error logs in BacklogQuotaManager (#11469)
(cherry picked from commit 084eebf77548a58d07f984c067fcd055d82e5afd)
---
.../org/apache/pulsar/broker/service/BacklogQuotaManager.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java
index c941b6c..fa0d24b 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java
@@ -191,13 +191,13 @@ public class BacklogQuotaManager {
}
// Skip messages on the slowest consumer
if (log.isDebugEnabled()) {
- log.debug("Skipping [{}] messages on slowest consumer [{}] having backlog entries : [{}]",
- messagesToSkip, slowestConsumer.getName(), entriesInBacklog);
+ log.debug("[{}] Skipping [{}] messages on slowest consumer [{}] having backlog entries : [{}]",
+ persistentTopic.getName(), messagesToSkip, slowestConsumer.getName(), entriesInBacklog);
}
slowestConsumer.skipEntries(messagesToSkip, IndividualDeletedEntries.Include);
} catch (Exception e) {
- log.error("Error skipping [{}] messages from slowest consumer : [{}]", messagesToSkip,
- slowestConsumer.getName());
+ log.error("[{}] Error skipping [{}] messages from slowest consumer [{}]", persistentTopic.getName(),
+ messagesToSkip, slowestConsumer.getName(), e);
}
// Make sure that unconsumed size is updated every time when we skip the messages.
@@ -250,7 +250,7 @@ public class BacklogQuotaManager {
ledgerInfo = mLedger.getLedgerInfo(ledgerId).get();
}
} catch (Exception e) {
- log.error("Error resetting cursor for slowest consumer [{}]: {}",
+ log.error("[{}] Error resetting cursor for slowest consumer [{}]", persistentTopic.getName(),
mLedger.getSlowestConsumer().getName(), e);
}
}