From 4d134f286276e1d2c68b78fa1f80f93d898d997e Mon Sep 17 00:00:00 2001 From: "f.kulakov" Date: Wed, 13 Mar 2019 10:42:04 +0300 Subject: [PATCH] stats_cb support --- pkg/rdkafka/RdKafkaContext.php | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/rdkafka/RdKafkaContext.php b/pkg/rdkafka/RdKafkaContext.php index cfe8e0eb1..22d4a8e47 100644 --- 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); }