Kerberos认证的ROUTINE LOAD

U_1672736046465_5481 · 2023年01月4日 07:24

谁能提供一个kafka开启了Kerberos认证的ROUTINE LOAD例子？谢了。

dongquan · 2023年01月5日 03:37

目前routine load 不支持Kerberos 认证，可以使用flink消费数据，然后使用flink-connector写入sr。

dongquan · 2023年12月27日 07:37

3.1.4版本开始支持，这几个配置在创建 routine load 的时候加一下就可以:
“property.security.protocol”=“SASL_PLAINTEXT”,

“property.sasl.mechanism”=“GSSAPI”,

“property.sasl.kerberos.service.name”=“kafka”,

“property.sasl.kerberos.keytab”="",

“property.sasl.kerberos.principal”=""