Support for AWS MSK: AWS_MSK_IAM sasl mechanism

[MarjanJordanovski]

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]

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

[zuerst]

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