diff --git a/plugins/messagebus_producers/kafka/kafka.py b/plugins/messagebus_producers/kafka/kafka.py
index 7720367..8cc7741 100644
--- a/plugins/messagebus_producers/kafka/kafka.py
+++ b/plugins/messagebus_producers/kafka/kafka.py
@@ -42,6 +42,7 @@ def __init__(self, settings: dict[str, Any]):
         self._kafkaconfig: dict[str, Any] = {
             "bootstrap_servers": self._settings["servers"],
             "security_protocol": "PLAINTEXT",
+            "max_request_size": self._settings["max_request_size"],
         }
 
         if "ssl" in self._settings:
@@ -52,7 +53,6 @@ def __init__(self, settings: dict[str, Any]):
                     "ssl_certfile": self._settings["ssl"]["certfile"],
                     "ssl_keyfile": self._settings["ssl"]["keyfile"],
                     "ssl_cafile": self._settings["ssl"]["cafile"],
-                    "max_request_size": self._settings["max_request_size"],
                 }
             )