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