是否需要这3个参数,或者下面参数是否支持?




'security.protocol'='SASL_PLAINTEXT',
'sasl.mechanism'='GSSAPI',
'sasl.kerberos.service.name'='kafka',












在 2020-07-30 16:38:11,"lydata" <[email protected]> 写道:
> flink v1.11.1  kafka使用了kerberos 
>下面DDL 是支持 kerberos 参数
>
>
>CREATETABLEkafkaTable(
>...
>)WITH('connector'='kafka',
>'topic'='user_behavior',
>'properties.bootstrap.servers'='localhost:9092',
>'properties.group.id'='testGroup', 'security.protocol'='SASL_PLAINTEXT',
>'sasl.mechanism'='GSSAPI',
>'sasl.kerberos.service.name'='kafka',
>'format'='csv',
>'scan.startup.mode'='earliest-offset'
>)
>
>
>是否支持上面的参数?

回复