I have an MSK cluster in AWS and am trying to connect using “Confluent.Kafka 1.8.2” SDK to connect with it, where I am providing the following config fields:
Producer :
BootstrapServers = “private end point address”,
StatisticsIntervalMs = 5000,
SaslMechanism = SaslMechanism.ScramSha512,
SaslUsername = “appropriate user name”,
SaslPassword = “password for the above user name”,
SecurityProtocol = SecurityProtocol.SaslSsl,
SslEndpointIdentificationAlgorithm = SslEndpointIdentificationAlgorithm.Https
Consumer:
BootstrapServers = “private end point address”,
GroupId = “FPS”,
EnableAutoCommit = true,
AutoOffsetReset = AutoOffsetReset.Earliest,
StatisticsIntervalMs = 5000,
SessionTimeoutMs = 6000,
SaslMechanism = SaslMechanism.ScramSha512,
SaslUsername = “appropriate user name”,
SaslPassword = “password for the above user name”,
SecurityProtocol = SecurityProtocol.SaslSsl,
SslEndpointIdentificationAlgorithm = SslEndpointIdentificationAlgorithm.Https,
Debug = “consumer,cgrp,topic,fetch”
but the application is still unable to produce or consume messages.
P.S : When I write to a topic which is not present I get a
“Broker: Unknown topic or partition” error, but when the topic is present I get “Message timed out” error.