SASL SCRAM disconnect

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

Hey @tomascaraccia,

Can you share the Stream Enrich config you are using, please ? Maybe we can spot something in there.

@enes_aldemir
The issue was a \ in the associated secret to msk.
Working now, thanks!

2 Likes

Thanks for accepting the solution - really helpful to other users!
Cheers,
Eddie