You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/03/27 16:10:00 UTC
[jira] [Updated] (FLINK-31361) job created by sql-client can't authenticate to kafka, can't find org.apache.kafka.common.security.plain.PlainLoginModule
[ https://issues.apache.org/jira/browse/FLINK-31361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-31361:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Labels: pull-request-available
>
> 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)