From 64ec9c1dfba7bb7bb4c9ebcb61123ae07dbaabde Mon Sep 17 00:00:00 2001 From: Adam Bettigole Date: Tue, 14 Jul 2026 17:31:54 -0700 Subject: [PATCH] changing noisy logs to debug level --- .../extension/messagequeue/mysql/partition_lease_store.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/platform/extension/messagequeue/mysql/partition_lease_store.go b/platform/extension/messagequeue/mysql/partition_lease_store.go index 23f803b3..6ea259e3 100644 --- a/platform/extension/messagequeue/mysql/partition_lease_store.go +++ b/platform/extension/messagequeue/mysql/partition_lease_store.go @@ -258,7 +258,7 @@ func (s *sqlpartitionLeaseStore) DiscoverAndAcquirePartitions(ctx context.Contex for _, partitionKey := range partitions { // Enforce maxPartitions cap using local count if maxPartitions > 0 && ownedCount >= maxPartitions { - s.logger.Infow("reached max partitions cap, stopping acquisition", + s.logger.Debugw("reached max partitions cap, stopping acquisition", logTopic, topic, "max_partitions", maxPartitions, "owned_count", ownedCount, @@ -291,7 +291,7 @@ func (s *sqlpartitionLeaseStore) DiscoverAndAcquirePartitions(ctx context.Contex metrics.NamedCounter(s.scope, "discover_and_acquire", "partitions_discovered", int64(len(partitions)), metrics.NewTag("topic", topic)) metrics.NamedCounter(s.scope, "discover_and_acquire", "partitions_acquired", int64(acquiredCount), metrics.NewTag("topic", topic)) - s.logger.Infow("completed partition discovery and acquisition", + s.logger.Debugw("completed partition discovery and acquisition", logTopic, topic, "discovered_count", len(partitions), "acquired_count", acquiredCount,