谢谢 ，我试试
在 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'
>>> )
>>>
>>>
>>> 是否支持上面的参数？
