From 5bc07fa388014351dfb5e7afc95d46e5e2d33529 Mon Sep 17 00:00:00 2001 From: fangchengjin Date: Wed, 22 Dec 2021 10:20:01 +0800 Subject: [PATCH] cancel send message info log --- producer/PartitionSender.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/producer/PartitionSender.go b/producer/PartitionSender.go index f266041..103f4f3 100644 --- a/producer/PartitionSender.go +++ b/producer/PartitionSender.go @@ -226,7 +226,7 @@ func (s *PartitionSender) putMessage(messageList []*message.Message) error { func (s *PartitionSender) AddMessage(userMessageList []*UserMessage) { s.partitionMessageQueue.AddMessage(userMessageList) - s.log.Infof("add %d messages to partition: %d", + s.log.Debugf("add %d messages to partition: %d", len(userMessageList), s.partitionId) }