Merge pull request #178 from akucherenko/fix-rdkafka-rebalance-cb

Fix typo in configuration parameter
php-enqueue · Aug 25, 2017 · f3c5e18 · f3c5e18
2 parents 8ec72a1 + a41ff32
commit f3c5e18
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);