From 0520fc1edeb7cd276c40af62119d1f147b48d49f Mon Sep 17 00:00:00 2001
From: pluto <2631223275@qq.com>
Date: Wed, 23 Aug 2023 16:33:33 +0800
Subject: [PATCH] kafka msg data conversion

---
 go.work                                     | 1 +
 tools/data-conversion/kafka-conversation.go | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/go.work b/go.work
index ce1770c8e..1924df501 100644
--- a/go.work
+++ b/go.work
@@ -8,4 +8,5 @@ use (
 	./tools/infra
 	./tools/ncpu
 	./tools/yamlfmt
+	./tools/data-conversion
 )
diff --git a/tools/data-conversion/kafka-conversation.go b/tools/data-conversion/kafka-conversation.go
index e37195afe..02f761b0b 100644
--- a/tools/data-conversion/kafka-conversation.go
+++ b/tools/data-conversion/kafka-conversation.go
@@ -97,7 +97,7 @@ func GetMessage() {
 			defer wg.Done()
 			for msg := range pc.Messages() {
 				Transfer([]*sarama.ConsumerMessage{msg})
-				fmt.Printf("Partition:%d, Offset:%d, Key:%s, Value:%s\n", msg.Partition, msg.Offset, string(msg.Key), string(msg.Value))
+				//fmt.Printf("Partition:%d, Offset:%d, Key:%s, Value:%s\n", msg.Partition, msg.Offset, string(msg.Key), string(msg.Value))
 			}
 		}(pc)