Hi @webe3, thanks for reaching out. Sounds like you're looking for pykafka's SSL support, which is based on constructing an SslConfig object and passing it to a newly created KafkaClient.

Yes, I saw that but it is not clear to me how to do it given what I have to work with.

It doesn't look to me like pykafka has the mechanism for sasl plain like kafka-python and confluent_kafka do. For example in kafka-python I would pass in the following configurations to create a consumer or producer.

configs = {
'bootstrap_servers': credentials['kafka_brokers_sasl'],
'sasl_mechanism': 'PLAIN',
'sasl_plain_username': credentials['api_key'][0:16],
'sasl_plain_password': credentials['api_key'][16:48],
'security_protocol': 'SASL_SSL',
'ssl_context': ssl.create_default_context(),
}

These parameters are described here: https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html

I don't see any similar parameters for sasl for pykafka.

Thanks for clarifying, @webe3. Pykafka indeed doesn't have SASL support, only TLS/SSL support at the moment. I've changed the title of this bug to indicate the need for SASL support. If you're interested in contributing a pull request for this feature, I'd be happy to review it. Otherwise, it will go into the issue backlog.

SASL support would be great. We're having to rewrite an internal project to use kafka-python for the time being due to the lack of SASL support.

Do we have SASL support enabled for PyKafka?

No, SASL support is still pending a pull request that adds it.

Our kafka prod server is moving to GSSAPI SASL (kerberos) authentication, so I would like to know are there any news regarding SASL support by pykafka?

我们的产品将更换抛弃pykafka，因为支持SASK，求支持~

in our products we use kafka and give up pykafka due to the lack of sasl support.
it will be great if pykafka support sasl

SASL is required in our project. pykafka is not support.