diff --git a/pkg/rdkafka/RdKafkaContext.php b/pkg/rdkafka/RdKafkaContext.php
index 3fba44e30..d8cbfc028 100644
--- a/pkg/rdkafka/RdKafkaContext.php
+++ b/pkg/rdkafka/RdKafkaContext.php
@@ -157,7 +157,7 @@ private function getConf()
             }
 
             if (isset($this->config['rebalance_cb'])) {
-                $this->conf->setRebalanceCb($this->config['errorebalance_cbr_cb']);
+                $this->conf->setRebalanceCb($this->config['rebalance_cb']);
             }
 
             $this->conf->setDefaultTopicConf($topicConf);