Flink Kafka Table API for python with JAAS

[Sweta Kalakuntla]

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: skalakun...@bandwidth.com