[improve][broker] Add logs for why namespace bundle been split (#19003)

(cherry picked from commit 8b66a21)
apache · Dec 21, 2022 · 60a4985 · 60a4985
1 parent 30f29eb
commit 60a4985
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...ar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java b/...ar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java
@@ -99,6 +99,12 @@ public Set<String> findBundlesToSplit(final LoadData loadData, final PulsarServi
                                 .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);