msg update

2 years ago · c21523f863
parent c0d72d91fb
commit c21523f863
1 changed files with 1 additions and 1 deletions
--- a/pkg/common/kafka/producer.go
+++ b/pkg/common/kafka/producer.go
@ -75,7 +75,7 @@ func (p *Producer) SendMessage(ctx context.Context, key string, m proto.Message)
 		{Key: []byte(constant.OpUserPlatform), Value: []byte(platform)},
 		{Key: []byte(constant.ConnID), Value: []byte(connID)}}
 	partition, offset, err := p.producer.SendMessage(kMsg)
-	log.ZDebug(ctx, "ByteEncoder SendMessage end", "key ", kMsg.Key.Length(), "key length", kMsg.Value.Length())
+	log.ZDebug(ctx, "ByteEncoder SendMessage end", "key ", kMsg.Key, "key length", kMsg.Value.Length())
 	if err == nil {
 		prome.Inc(prome.SendMsgCounter)
 	}