Beats Kafka Output: support for SASL OAUTH and MSK IAM Authentication

Elastic Stack Beats
,
1

Hi,

We are interested in sending logs with Filebeat to an MSK cluster using IAM authentication. Currently, the Kafka Output does not support SASL OAUTH, which is the underlying mechanism for IAM Authentication (see a Golang example: GitHub Link).

We are willing to submit a PR to add support for this use case if that works for you.

thanks!