David Anderson created FLINK-31361:
--------------------------------------
Summary: 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
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)
