From b3a1320876ccb197e37dbab2aabaca7a42208394 Mon Sep 17 00:00:00 2001
From: Matthias Wessendorf <mwessend@redhat.com>
Date: Fri, 13 Sep 2019 11:45:30 +0200
Subject: [PATCH] add Offset setting

---
 README.md | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/README.md b/README.md
index 66fafcf..3a656bb 100644
--- a/README.md
+++ b/README.md
@@ -66,6 +66,9 @@ func main() {
 		Concurrency: 100, // number of go routines processing messages in parallel
 	}
 
+	// receive all messages on the topic
+	config.Offsets.Initial.Offset = kafka.OffsetOldest
+
 	// Create the consumer through the previously created client
 	consumer, err := client.NewConsumer(config)
 	if err != nil {