Hi,
I am using Flink 1.11.2 version Python Table API to connect to Kafka Topic
using SASL protocol but it fails with the following error. I tried the same
properties in Flink java version, and I am able to connect. Has anyone
faced this issue and how did you resolve it?
Error:
Caused by: javax.security.auth.login.LoginException: unable to find
LoginModule class:
org.apache.kafka.common.security.plain.PlainLoginModule
Kafka connection:
kafka = Kafka()\
.version("universal") \
.topic("test_topic")\
.property("group.id", "consumer_group")\
.property("security.protocol", "SASL_PLAINTEXT")\
.property("sasl.mechanism", "PLAIN")\
.property("bootstrap.servers",
"<remoteIP>:9093")\
.property("sasl.jaas.config",
"org.apache.kafka.common.security.plain.PlainLoginModule required
username=\"user\" "
"password=\"abc\";")\
.start_from_latest()
Thank you,
SKala
--
[image: BandwidthBlue.png]
Sweta Kalakuntla • Software Engineer
900 Main Campus Drive, Raleigh, NC 27606
m: 216-702-1653
e: [email protected]
