是否需要这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' >) > > >是否支持上面的参数?
