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

Fix typo in configuration parameter
php-enqueue · Aug 25, 2017 · b822eb7 · b822eb7
2 parents 0fad9dc + 0b1b0c4
commit b822eb7
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);