kafka msg data conversion

go.work

@@ -8,4 +8,5 @@ use (
 	./tools/infra
 	./tools/ncpu
 	./tools/yamlfmt
+	./tools/data-conversion
 )

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)