Re: flink kafka SQL Connectors 传递kerberos 参数

不知道你的问题是能否通过这个解决 我看了下目前文档里缺少了传递kafka properties 的部分，我建了个issue[1]把文档补齐 Best Leonard [1] https://issues.apache.org/jira/browse/FLINK-18768 > 在 2020年7月30日，17:52，lydata 写道： > > > > > > > > 谢谢 ，我试试 > > > > > > > > > > > > > >

Re:Re: flink kafka SQL Connectors 传递kerberos 参数

谢谢 ，我试试 在 2020-07-30 17:34:41，"Leonard Xu" 写道： >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

Re: flink kafka SQL Connectors 传递kerberos 参数

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 写道： > > > > 是否需要这3个参数，或者下面参数是否支持？ > > > > >

flink kafka SQL Connectors 传递kerberos 参数

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',