diff --git a/aiokafka/consumer/consumer.py b/aiokafka/consumer/consumer.py index e01e0299..6a1139cb 100644 --- a/aiokafka/consumer/consumer.py +++ b/aiokafka/consumer/consumer.py @@ -168,7 +168,8 @@ class AIOKafkaConsumer: If set to ``auto``, will attempt to infer the broker version by probing various APIs. Default: ``auto`` security_protocol (str): Protocol used to communicate with brokers. - Valid values are: ``PLAINTEXT``, ``SSL``. Default: ``PLAINTEXT``. + Valid values are: ``PLAINTEXT``, ``SSL``, ``SASL_PLAINTEXT``, + ``SASL_SSL``. Default: ``PLAINTEXT``. ssl_context (ssl.SSLContext): pre-configured :class:`~ssl.SSLContext` for wrapping socket connections. Directly passed into asyncio's :meth:`~asyncio.loop.create_connection`. For more information see diff --git a/aiokafka/producer/producer.py b/aiokafka/producer/producer.py index 98b10fb7..5fb7e02f 100644 --- a/aiokafka/producer/producer.py +++ b/aiokafka/producer/producer.py @@ -138,8 +138,8 @@ class AIOKafkaProducer: If set to ``auto``, will attempt to infer the broker version by probing various APIs. Default: ``auto`` security_protocol (str): Protocol used to communicate with brokers. - Valid values are: ``PLAINTEXT``, ``SSL``. Default: ``PLAINTEXT``. - Default: ``PLAINTEXT``. + Valid values are: ``PLAINTEXT``, ``SSL``, ``SASL_PLAINTEXT``, + ``SASL_SSL``. Default: ``PLAINTEXT``. ssl_context (ssl.SSLContext): pre-configured :class:`~ssl.SSLContext` for wrapping socket connections. Directly passed into asyncio's :meth:`~asyncio.loop.create_connection`. For more