From cc3d805015ea04382c975143bfcb8793e53ce1bc Mon Sep 17 00:00:00 2001
From: pluto <2631223275@qq.com>
Date: Tue, 22 Aug 2023 15:41:46 +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 cc8ee61e4..c8728eb53 100644
--- a/test/data-conversion/kafka-conversation.go
+++ b/test/data-conversion/kafka-conversation.go
@@ -74,7 +74,7 @@ func GetMessage() {
 	}
 	fmt.Println(partitionList)
 	for partition := range partitionList {
-		pc, err := consumer.ConsumePartition(topic, int32(partition), sarama.OffsetNewest)
+		pc, err := consumer.ConsumePartition(topic, int32(partition), sarama.OffsetOldest)
 		if err != nil {
 			panic(err)
 		}