kafka msg data conversion

2 years ago · b2b9b8f95f
parent df9613c49b
commit b2b9b8f95f
1 changed files with 1 additions and 1 deletions
--- 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)
 		}