不知道你的问题是能否通过这个解决 我看了下目前文档里缺少了传递kafka properties 的部分,我建了个issue[1]把文档补齐
Best Leonard [1] https://issues.apache.org/jira/browse/FLINK-18768 <https://issues.apache.org/jira/browse/FLINK-18768> > 在 2020年7月30日,17:52,lydata <lydata_...@163.com> 写道: > > > > > > > > 谢谢 ,我试试 > > > > > > > > > > > > > > > 在 2020-07-30 17:34:41,"Leonard Xu" <xbjt...@gmail.com> 写道: >> Hi, >> kafka properties 的参数是可以透传的,你试试下面: >> >> ‘properties.security.protocol'='SASL_PLAINTEXT', >> ‘properties.sasl.mechanism'='GSSAPI’, >> ‘properties.sasl.kerberos.service.name'='kafka', >> >> 祝好 >> Leonard >> >> >>> 在 2020年7月30日,17:00,lydata <lydata_...@163.com> 写道: >>> >>> >>> >>> 是否需要这3个参数,或者下面参数是否支持? >>> >>> >>> >>> >>> 'security.protocol'='SASL_PLAINTEXT', >>> 'sasl.mechanism'='GSSAPI', >>> 'sasl.kerberos.service.name'='kafka', >>> >>> >>> >>> >>> >>> >>> >>> >>> >>> >>> >>> >>> 在 2020-07-30 16:38:11,"lydata" <lydata_...@163.com> 写道: >>>> 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' >>>> ) >>>> >>>> >>>> 是否支持上面的参数?