🐛 'plugins.messagebus_producers.kafka' : Fixed the 'plugins.messagebu…

…s.kafka.settings.max_request_size' initialization location : it was ignored if 'plugins.messagebus.kafka.settings.ssl' wasn't set

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"],
                 }
             )