[pulsar] branch branch-2.11 updated: [improve][broker] Add logs for why namespace bundle been split (#19003)

[penghui]

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

penghui pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.11 by this push:
     new e0a73e0cbce [improve][broker] Add logs for why namespace bundle been 
split (#19003)
e0a73e0cbce is described below

commit e0a73e0cbce647ac4ddce788fff8a4cd13d5bdf7
Author: Penghui Li <peng...@apache.org>
AuthorDate: Wed Dec 21 07:38:08 2022 +0800

    [improve][broker] Add logs for why namespace bundle been split (#19003)
    
    (cherry picked from commit 8b66a21ef4101c5726b362788ca746d390c7bf38)
---
 .../apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java   | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java
index 480f466c2ab..7574eab4105 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java
@@ -102,6 +102,12 @@ public class BundleSplitterTask implements 
BundleSplitStrategy {
                                 .getBundleCount(NamespaceName.get(namespace));
                         if ((bundleCount + 
namespaceBundleCount.getOrDefault(namespace, 0))
                                 < maxBundleCount) {
+                            log.info("The bundle {} is considered to be 
unload. Topics: {}/{}, Sessions: ({}+{})/{}, "
+                                            + "Message Rate: {}/{} (msgs/s), 
Message Throughput: {}/{} (MB/s)",
+                                    bundle, stats.topics, maxBundleTopics, 
stats.producerCount, stats.consumerCount,
+                                    maxBundleSessions, totalMessageRate, 
maxBundleMsgRate,
+                                    totalMessageThroughput / 
LoadManagerShared.MIBI,
+                                    maxBundleBandwidth / 
LoadManagerShared.MIBI);
                             bundleCache.add(bundle);
                             int bundleNum = 
namespaceBundleCount.getOrDefault(namespace, 0);
                             namespaceBundleCount.put(namespace, bundleNum + 1);