diff --git a/options.go b/options.go
index 4f7eae3..b7f8d98 100644
--- a/options.go
+++ b/options.go
@@ -116,3 +116,10 @@ type subscribeMessagePoolKey struct{}
 func SubscribeMessagePool(b bool) broker.SubscribeOption {
 	return broker.SetSubscribeOption(subscribeMessagePoolKey{}, b)
 }
+
+type subscribeMessagePoolKey struct{}
+
+// SubscribeMessagePool optionaly enabled/disable message pool
+func SubscribeMessagePool(b bool) broker.SubscribeOption {
+	return broker.SetSubscribeOption(subscribeMessagePoolKey{}, b)
+}
diff --git a/subscriber.go b/subscriber.go
index c61854a..e7557b8 100644
--- a/subscriber.go
+++ b/subscriber.go
@@ -39,6 +39,7 @@ type consumer struct {
 }
 
 type Subscriber struct {
+<<<<<<< HEAD
 	consumers    map[tp]*consumer
 	c            *kgo.Client
 	htracer      *hookTracer