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 <[email protected]> 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); } }
