Support for AWS MSK: AWS_MSK_IAM sasl mechanism

dpkp / kafka-python

Python client for Apache Kafka

http://kafka-python.readthedocs.io/

Apache License 2.0

5.6k stars 1.41k forks source link

Support for AWS MSK: AWS_MSK_IAM sasl mechanism #2313

Open MarjanJordanovski opened 2 years ago

MarjanJordanovski commented 2 years ago

Hello,

I have a MSK cluster, and connected my EC2 instance with it.

I would like to create a python script on that EC2, which will produce to, and consume from topics in my MSK cluster. Is it possible at the moment? I guess Producer needs to have sasl_mechanism='AWS_MSK_IAM' set, which I believe is not supported mechanism?

piyush-daga commented 2 years ago

You can have a look at this forked code which adds support for AWS_MSK_IAM

zuerst commented 7 months ago

AWS officially released msk ism sasl singer and it has example using dpkp/kafka-python. Take a look at this