This message was deleted.
# general
s
This message was deleted.
s
You can add additional consumer properties to the ingestion spec that are used to establish the connection. Here's an example:
consumerProperties are any kafka consumer config setting you want to use, like:
Copy code
{
  "bootstrap.servers": "<kafka bootstrap servers>",
  "security.protocol": "SASL_SSL",
  "sasl.mechanism": "AWS_MSK_IAM",
  "sasl.jaas.config": "software.amazon.msk.auth.iam.IAMLoginModule required awsRoleArn='arn:aws:iam::xxxxxxxxx:role/msk-imply-dev' awsRoleSessionName='xxxxxxxx' awsStsRegion='us-east-1';",
  "sasl.client.callback.handler.class": "software.amazon.msk.auth.iam.IAMClientCallbackHandler"
}
k
Thanks @Sergio Ferragut