Hi,
are you using the SQL jars or do you build the dependency jar file
yourself? It might be the case that the SQL jar for Kafka does not
include this module as the exception indicates. You might need to build
a custom Kafka jar with Maven and all dependencies you need. (including
correct META-INF/services entries).
I hope this helps.
Regards,
Timo
On 10.11.20 05:11, Sweta Kalakuntla wrote:
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 <http://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
--
BandwidthBlue.png
Sweta Kalakuntla•Software Engineer
900 Main Campus Drive, Raleigh, NC 27606
m:216-702-1653
e: skalakun...@bandwidth.com <http://bandwidth.com>
