Flink配置消息队列Kafka源表时，Kafka集群需要SASL（Simple Authentic

CREATE TABLE kafkaTable (

...

) WITH (

...

'properties.security.protocol' = 'SASL_PLAINTEXT',

'properties.sasl.mechanism' = 'PLAIN',

'properties.sasl.jaas.config' = 'org.apache.flink.kafka.shaded.org.apache.kafka.common.security.plain.PlainLoginModule required username="USERNAME" password="PASSWORD";'

);

注意：仅Per-Job集群支持Kafka认证，更多内容可参考文档：消息队列Kafka源表