@@ -258,7 +258,7 @@ func (s *sqlpartitionLeaseStore) DiscoverAndAcquirePartitions(ctx context.Contex
258258 for _ , partitionKey := range partitions {
259259 // Enforce maxPartitions cap using local count
260260 if maxPartitions > 0 && ownedCount >= maxPartitions {
261- s .logger .Infow ("reached max partitions cap, stopping acquisition" ,
261+ s .logger .Debugw ("reached max partitions cap, stopping acquisition" ,
262262 logTopic , topic ,
263263 "max_partitions" , maxPartitions ,
264264 "owned_count" , ownedCount ,
@@ -291,7 +291,7 @@ func (s *sqlpartitionLeaseStore) DiscoverAndAcquirePartitions(ctx context.Contex
291291
292292 metrics .NamedCounter (s .scope , "discover_and_acquire" , "partitions_discovered" , int64 (len (partitions )), metrics .NewTag ("topic" , topic ))
293293 metrics .NamedCounter (s .scope , "discover_and_acquire" , "partitions_acquired" , int64 (acquiredCount ), metrics .NewTag ("topic" , topic ))
294- s .logger .Infow ("completed partition discovery and acquisition" ,
294+ s .logger .Debugw ("completed partition discovery and acquisition" ,
295295 logTopic , topic ,
296296 "discovered_count" , len (partitions ),
297297 "acquired_count" , acquiredCount ,
0 commit comments