From 07307d0beff7f6c779f5dd0ea6ce06013ee19bbd Mon Sep 17 00:00:00 2001
From: pluto <2631223275@qq.com>
Date: Tue, 22 Aug 2023 15:56:23 +0800
Subject: [PATCH] kafka msg data conversion

---
 test/data-conversion/kafka-conversation.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/test/data-conversion/kafka-conversation.go b/test/data-conversion/kafka-conversation.go
index 4bf8a1110..9de04c580 100644
--- a/test/data-conversion/kafka-conversation.go
+++ b/test/data-conversion/kafka-conversation.go
@@ -90,7 +90,7 @@ func GetMessage() {
 		}(pc)
 		//wg.Add(1)
 		//wg.Wait()
-		consumer.Close()
 	}
+	consumer.Close()
 	_ = <-ch
 }