尝试实现数据流（apachebeam作业）以使用kerberos凭据连接到kafka代理。
据我所知-
使用kafkaio.read.withconsumerfactoryfn提供工厂函数，该函数将被调用以创建kafka使用者。这将占用ssl凭据的个数
为kerberos凭据创建配置文件-kafka客户端配置（带keytab），用于生产者：
kafkaclient{com.sun.security.auth.module.krb5loginmodule required usekeytab=true keytab=“/etc/security/keytab/storm.service.keytab”storekey=true useticketcache=false servicename=“kafka”principal=”storm@example.com"; };
请任何人指导如何将这一点结合起来，以一个有效的解决方案。
谢谢