From da1ae7157bc6c2688560cad7322d2f66246ec1a4 Mon Sep 17 00:00:00 2001 From: pluto <2631223275@qq.com> Date: Wed, 23 Aug 2023 16:52:56 +0800 Subject: [PATCH] tools for conversion --- tools/data-conversion/kafka-conversation.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/tools/data-conversion/kafka-conversation.go b/tools/data-conversion/kafka-conversation.go index 4d9b3547a..83ec57a89 100644 --- a/tools/data-conversion/kafka-conversation.go +++ b/tools/data-conversion/kafka-conversation.go @@ -106,11 +106,12 @@ func GetMessage() { msgFromMQ := &sdkws.MsgData{} err := proto.Unmarshal(msg.Value, msgFromMQ) if err != nil { - fmt.Printf("err:%s", err) + fmt.Printf("err:%s \n", err) } - fmt.Printf("msg:%s", msgFromMQ) + fmt.Printf("msg:%s \n", msgFromMQ) //fmt.Printf("Partition:%d, Offset:%d, Key:%s, Value:%s\n", msg.Partition, msg.Offset, string(msg.Key), string(msg.Value)) } + }(pc) }