func main() {
r := kafka.NewReader(kafka.ReaderConfig{
Brokers: []string{"localhost:9092"},
Topic: "my-topic",
Partition: 0,
MaxBytes: 10e6, // 10MB
})
for {
m, err := r.ReadMessage(context.Background())
if err != nil {
break
}
fmt.Printf("message at offset %d: %s = %s\n", m.Offset, string(m.Key), string(m.Value))
r.CommitMessages(context.Background(), m) // commit offset
}

if err := r.Close(); err != nil {
	log.Fatal("failed to close reader:", err)
}

}

I submitted the offset, but each time I execute the program, it starts from the beginning, resulting in repeated consumption.

===============First Execution===========
message at offset 0: = one!
message at offset 1: = two!
message at offset 2: = three!

============== Second Execution =========
message at offset 0: = one!
message at offset 1: = two!
message at offset 2: = three!