Fix typo in configuration parameter

akucherenko · akucherenko · commit 0b1b0c4bad5a · 2017-08-25T16:04:39.000+02:00
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);`