View Source KafkaEx.Auth.SASL.MskIam (kafka_ex v1.0.0-rc.1)

SASL/OAUTHBEARER mechanism for AWS MSK IAM authentication.

Uses AWS SigV4 presigned request as OAUTHBEARER token for MSK clusters configured with IAM authentication.

Configuration

config :kafka_ex,
  brokers: [{"b-1.mycluster.kafka.us-east-1.amazonaws.com", 9098}],
  use_ssl: true,
  sasl: %{
    mechanism: :msk_iam,
    mechanism_opts: %{region: "us-east-1"}
  }

Credentials

Resolved in order: credential_provider function, explicit keys, aws_credentials library.