Added SASL username & pw to SASL-SSL producer (#7528)

RasaHQ · Dec 11, 2020 · bb2247c · bb2247c
1 parent b18f700
commit bb2247c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/rasa/core/brokers/kafka.py b/rasa/core/brokers/kafka.py
@@ -124,6 +124,8 @@ def _create_producer(self) -> None:
                 ssl_certfile=self.ssl_certfile,
                 ssl_keyfile=self.ssl_keyfile,
                 ssl_check_hostname=False,
+                sasl_plain_username=self.sasl_username,
+                sasl_plain_password=self.sasl_password,
                 sasl_mechanism="PLAIN",
                 security_protocol=self.security_protocol,
                 client_id=self.client_id,