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); } } }