You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by lydata <ly...@163.com> on 2020/07/30 08:38:11 UTC
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',
'sasl.kerberos.service.name'='kafka',
'format'='csv',
'scan.startup.mode'='earliest-offset'
)
是否支持上面的参数？
Re: flink kafka SQL Connectors 传递kerberos 参数
Posted by Leonard Xu <xb...@gmail.com>.
不知道你的问题是能否通过这个解决
我看了下目前文档里缺少了传递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 <ly...@163.com> 写道：
>
>
>
>
>
>
>
> 谢谢 ，我试试
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2020-07-30 17:34:41，"Leonard Xu" <xb...@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 <ly...@163.com> 写道：
>>>
>>>
>>>
>>> 是否需要这3个参数，或者下面参数是否支持？
>>>
>>>
>>>
>>>
>>> 'security.protocol'='SASL_PLAINTEXT',
>>> 'sasl.mechanism'='GSSAPI',
>>> 'sasl.kerberos.service.name'='kafka',
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>>
>>> 在 2020-07-30 16:38:11，"lydata" <ly...@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'
>>>> )
>>>>
>>>>
>>>> 是否支持上面的参数？
Re:Re: flink kafka SQL Connectors 传递kerberos 参数
Posted by lydata <ly...@163.com>.
谢谢 ，我试试
在 2020-07-30 17:34:41，"Leonard Xu" <xb...@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 <ly...@163.com> 写道：
>>
>>
>>
>> 是否需要这3个参数，或者下面参数是否支持？
>>
>>
>>
>>
>> 'security.protocol'='SASL_PLAINTEXT',
>> 'sasl.mechanism'='GSSAPI',
>> 'sasl.kerberos.service.name'='kafka',
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> 在 2020-07-30 16:38:11，"lydata" <ly...@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'
>>> )
>>>
>>>
>>> 是否支持上面的参数？
Re: flink kafka SQL Connectors 传递kerberos 参数
Posted by Leonard Xu <xb...@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 <ly...@163.com> 写道：
>
>
>
> 是否需要这3个参数，或者下面参数是否支持？
>
>
>
>
> 'security.protocol'='SASL_PLAINTEXT',
> 'sasl.mechanism'='GSSAPI',
> 'sasl.kerberos.service.name'='kafka',
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2020-07-30 16:38:11，"lydata" <ly...@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'
>> )
>>
>>
>> 是否支持上面的参数？
Re:flink kafka SQL Connectors 传递kerberos 参数
Posted by lydata <ly...@163.com>.
是否需要这3个参数，或者下面参数是否支持？
'security.protocol'='SASL_PLAINTEXT',
'sasl.mechanism'='GSSAPI',
'sasl.kerberos.service.name'='kafka',
在 2020-07-30 16:38:11，"lydata" <ly...@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'
>)
>
>
>是否支持上面的参数？