|
|
Hi,
我尝试消费SASL机制的Kafka集群
jaas.conf 文件内容:
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin001"
password="123456";
};
执行命令如下:
export KAFKA_OPTS="-Djava.security.auth.login.config=/etc/jaas.conf"
./bin/sql-client.sh embedded
CREATE TABLE t1
(vendor STRING)
WITH (
'connector' = 'kafka',
'topic' = 'test',
'properties.bootstrap.servers' = '127.0.0.1:9092',
'properties.group.id' = 'g1',
'properties.sasl.mechanisms'='PLAIN',
'properties.sasl.username'='admin001',
'properties.sasl.password'='123456',
'properties.security.protocol'='SASL_PLAINTEXT',
'format' = 'json',
'scan.startup.mode' = 'earliest-offset',
'json.fail-on-missing-field' = 'false',
'json.ignore-parse-errors' = 'true'
);
然后报错提示:
Flink SQL> select * from t1;
[ERROR] Could not execute SQL statement. Reason:
java.lang.IllegalArgumentException: No serviceName defined in either JAAS or Kafka config
请教下, 这个该如何解决?
Thx
|
Locked
