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.