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); }