hi, 根据文档[1][2]， 你可以通过在with参数内填相应的内容来通过认证, e.g
'properties.sasl.kerberos.service.name' = 'xyz' [1] https://kafka.apache.org/documentation/#brokerconfigs_sasl.kerberos.service.name [2] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/kafka.html#properties 瞿叶奇 <[email protected]> 于2021年1月31日周日 下午2:26写道： > 您好，我是国网陕西采集系统开发人员，我们在架构改造中，准备使用pyflink > 解决实时Kafka数据写HDFS的问题，我的Kafka集群存在kerberos安全认证，导致我现在还没连接上，能不能给一个样例呢？
