From 94baf142d5895a4d32375f26ca8ba771ca88f6e7 Mon Sep 17 00:00:00 2001
From: fab0492 <145767364+fab0492@users.noreply.github.com>
Date: Wed, 19 Mar 2025 18:01:47 +0100
Subject: [PATCH] Update RdKafkaContext.php

allow to set log_cb via configuration
---
 RdKafkaContext.php | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/RdKafkaContext.php b/RdKafkaContext.php
index a252fcf..c6bbdef 100644
--- a/RdKafkaContext.php
+++ b/RdKafkaContext.php
@@ -205,6 +205,10 @@ private function getConf(): Conf
                 $this->conf->setDrMsgCb($this->config['dr_msg_cb']);
             }
 
+            if (isset($this->config['log_cb'])) {
+                $this->conf->setLogCb($this->config['log_cb']);
+            }
+
             if (isset($this->config['error_cb'])) {
                 $this->conf->setErrorCb($this->config['error_cb']);
             }