Im currently using SASL/SCRAM to connect to MSK.
[main] INFO com.snowplowanalytics.snowplow.enrich.stream.sources.KafkaSource - Processing raw input Kafka topic: snowplow-raw-good
[main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-snowplow-1, groupId=snowplow] Subscribed to topic(s): snowplow-raw-good
[main] INFO org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer clientId=consumer-snowplow-1, groupId=snowplow] Subscribed to topic(s): snowplow-raw-good
Odd thing is producer is not being able to connect using same authentication mechanism SASL/SCRAM
2022-04-12T11:46:45.332-03:00 [kafka-producer-network-thread | producer-2] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-2] Bootstrap broker b-1.testing-snowplow-msk.fl3nwv.c35.kafka.us-east-1.amazonaws.com:9096 (id: -1 rack: null) disconnected
2022-04-12T11:46:45.639-03:00 [kafka-producer-network-thread | producer-1] INFO org.apache.kafka.common.network.Selector - [Producer clientId=producer-1] Failed authentication with b-3.testing-snowplow-msk.fl3nwv.c35.kafka.us-east-1.amazonaws.com/10.43.15.165 (Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-512)
2022-04-12T11:46:45.639-03:00 [kafka-producer-network-thread | producer-1] ERROR org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Connection to node -3 (b-3.testing-snowplow-msk.fl3nwv.c35.kafka.us-east-1.amazonaws.com/10.43.15.165:9096) failed authentication due to: Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-512