From 993e9b9e97048a9aa2979b6db273ea48ecbfb8b9 Mon Sep 17 00:00:00 2001
From: Nick <nickjobszh@gmail.com>
Date: Wed, 30 Dec 2020 10:03:09 +0100
Subject: [PATCH] fix callback (#48)

---
 src/Consumer/KafkaConsumerBuilder.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Consumer/KafkaConsumerBuilder.php b/src/Consumer/KafkaConsumerBuilder.php
index 95b0d96..51b3ead 100644
--- a/src/Consumer/KafkaConsumerBuilder.php
+++ b/src/Consumer/KafkaConsumerBuilder.php
@@ -358,7 +358,7 @@ private function registerCallbacks(KafkaConfiguration $conf): void
         }
 
         if (null !== $this->offsetCommitCallback) {
-            $conf->setOffsetCommitCb($this->rebalanceCallback);
+            $conf->setOffsetCommitCb($this->offsetCommitCallback);
         }
     }
 }