KafkaCtl with AWS MSK and IAM auth

[Joel-PeakMetrics]

Hello,

I'd like to use KafkaCtl with AWS MSK. The MSK cluster is currently enabled with IAM auth only. Is there a way to enable kafkactl to use IAM SASL auth?

This configuration is working for the kafka java commands:

security.protocol=SASL_SSL
sasl.mechanism=AWS_MSK_IAM
sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required;
sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler

Thanks for your help!

[d-rk]

Hi @Joel-PeakMetrics

that is currently not possible. There is an open issue (and a related PR) in the kafka library we use: https://github.com/Shopify/sarama/issues/1985

When something happens with that issue we can look into this again.

Regards

[alahijani]

@d-rk The IBM/sarama issue is now closed.

[d-rk]

It should now be possible to implement this using: https://github.com/aws/aws-msk-iam-sasl-signer-go