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