stats_cb support

f.kulakov · f.kulakov · commit 4d134f286276 · 2019-03-13T10:42:04.000+03:00
diff --git a/pkg/rdkafka/RdKafkaContext.php b/pkg/rdkafka/RdKafkaContext.php
@@ -186,6 +186,10 @@ private function getConf(): Conf
                 $this->conf->setRebalanceCb($this->config['rebalance_cb']);
             }
 
+            if (isset($this->config['stats_cb'])) {
+                $this->conf->setStatsCb($this->config['stats_cb']);
+            }
+
             $this->conf->setDefaultTopicConf($topicConf);
         }
 

Original file line number	Diff line number	Diff line change
`@@ -186,6 +186,10 @@ private function getConf(): Conf`
`186`	`186`	`$this->conf->setRebalanceCb($this->config['rebalance_cb']);`
`187`	`187`	`}`
`188`	`188`
	`189`	`+ if (isset($this->config['stats_cb'])) {`
	`190`	`+ $this->conf->setStatsCb($this->config['stats_cb']);`
	`191`	`+ }`
	`192`	`+`
`189`	`193`	`$this->conf->setDefaultTopicConf($topicConf);`
`190`	`194`	`}`
`191`	`195`