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

makasim · web-flow · commit b822eb7bd6a8 · 2017-08-25T18:20:02.000+03:00
Fix typo in configuration parameter
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);

Original file line number	Diff line number	Diff line change
`@@ -157,7 +157,7 @@ private function getConf()`
`157`	`157`	`}`
`158`	`158`
`159`	`159`	`if (isset($this->config['rebalance_cb'])) {`
`160`		`- $this->conf->setRebalanceCb($this->config['errorebalance_cbr_cb']);`
	`160`	`+ $this->conf->setRebalanceCb($this->config['rebalance_cb']);`
`161`	`161`	`}`
`162`	`162`
`163`	`163`	`$this->conf->setDefaultTopicConf($topicConf);`