[ https://issues.apache.org/jira/browse/FLINK-31361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751485#comment-17751485 ]
Leonard Xu commented on FLINK-31361: ------------------------------------ I checked the error still exits in https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/kafka/#security, we can improve the documentation at least. [~danderson] Would you like to improve the documentation ? > job created by sql-client can't authenticate to kafka, can't find > org.apache.kafka.common.security.plain.PlainLoginModule > ------------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-31361 > URL: https://issues.apache.org/jira/browse/FLINK-31361 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka > Affects Versions: 1.16.1 > Reporter: David Anderson > Priority: Major > > I'm working with this SQL DDL: > {noformat} > CREATE TABLE pageviews_sink ( > `url` STRING, > `user_id` STRING, > `browser` STRING, > `ts` TIMESTAMP_LTZ(3) > ) WITH ( > 'connector' = 'kafka', > 'topic' = 'pageviews', > 'properties.bootstrap.servers' = 'xxx.confluent.cloud:9092', > 'properties.security.protocol'='SASL_SSL', > 'properties.sasl.mechanism'='PLAIN', > > 'properties.sasl.jaas.config'='org.apache.kafka.common.security.plain.PlainLoginModule > required username="xxx" password="xxx";', > 'key.format' = 'json', > 'key.fields' = 'url', > 'value.format' = 'json' > ); > {noformat} > With {{flink-sql-connector-kafka-1.16.1.jar}} in the lib directory, this > fails with > {noformat} > Caused by: javax.security.auth.login.LoginException: No LoginModule found for > org.apache.kafka.common.security.plain.PlainLoginModule{noformat} > As a workaround I've found that it does work if I provide both > > {{flink-connector-kafka-1.16.1.jar}} > {{kafka-clients-3.2.3.jar}} > > in the lib directory. It seems like the relocation applied in the SQL > connector isn't working properly. -- This message was sent by Atlassian Jira (v8.20.10#820010)