Closed gabrielmbmb closed 1 year ago
Describe the bug
The security_protocol argument docstring in aiokafka.{AIOKafkaConsumer, AIOKafkaProducer} does not mention SASL_SSL and SASL_PLAINTEXT as possible values but they are as mentioned in the sasl_mechanism argument docstring.
security_protocol
aiokafka.{AIOKafkaConsumer, AIOKafkaProducer}
SASL_SSL
SASL_PLAINTEXT
sasl_mechanism
https://github.com/aio-libs/aiokafka/blob/57439a6dfacabbd8fe591cafb6d116224a8132da/aiokafka/producer/producer.py#L140-L142
https://github.com/aio-libs/aiokafka/blob/57439a6dfacabbd8fe591cafb6d116224a8132da/aiokafka/consumer/consumer.py#L170-L171
aiokafka.client.AIOKafkaClient does mention all the possible values:
aiokafka.client.AIOKafkaClient
https://github.com/aio-libs/aiokafka/blob/57439a6dfacabbd8fe591cafb6d116224a8132da/aiokafka/client.py#L77-L79
Expected behaviour security_protocol argument docstring mentions SASL_SSL and SASL_PLAINTEXT as possible values.
Environment (please complete the following information):
python -c "import aiokafka; print(aiokafka.__version__)"
python -c "import kafka; print(kafka.__version__)"
kafka-topics.sh --version
Describe the bug
The
security_protocol
argument docstring inaiokafka.{AIOKafkaConsumer, AIOKafkaProducer}
does not mentionSASL_SSL
andSASL_PLAINTEXT
as possible values but they are as mentioned in thesasl_mechanism
argument docstring.https://github.com/aio-libs/aiokafka/blob/57439a6dfacabbd8fe591cafb6d116224a8132da/aiokafka/producer/producer.py#L140-L142
https://github.com/aio-libs/aiokafka/blob/57439a6dfacabbd8fe591cafb6d116224a8132da/aiokafka/consumer/consumer.py#L170-L171
aiokafka.client.AIOKafkaClient
does mention all the possible values:https://github.com/aio-libs/aiokafka/blob/57439a6dfacabbd8fe591cafb6d116224a8132da/aiokafka/client.py#L77-L79
Expected behaviour
security_protocol
argument docstring mentionsSASL_SSL
andSASL_PLAINTEXT
as possible values.Environment (please complete the following information):
python -c "import aiokafka; print(aiokafka.__version__)"
): 0.8.0python -c "import kafka; print(kafka.__version__)"
):kafka-topics.sh --version
):