From be82d76d81b13be18086a9eacb8e195cba646164 Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Mon, 20 Apr 2020 16:20:34 +0300
Subject: [PATCH] broker/segmentio: fix error

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
---
 segmentio.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/segmentio.go b/segmentio.go
index b039e16..f159101 100644
--- a/segmentio.go
+++ b/segmentio.go
@@ -233,6 +233,7 @@ func (k *kBroker) Subscribe(topic string, handler broker.Handler, opts ...broker
 					cfg := k.readerConfig
 					cfg.Topic = topic
 					cfg.Partition = partition
+					cfg.GroupID = ""
 					reader := kafka.NewReader(cfg)
 					defer reader.Close()
 					// seek to the last committed offset for this partition.