具有kerberos凭证的Apache Beam + kafka客户端

问题描述

尝试实现数据流（Apache Beam作业）以使用Kerberos凭据连接到Kafka broker。

据我了解-

1. 使用KafkaIO.Read.withConsumerFactoryFn提供工厂函数，该函数将被调用以创建Kafka使用者。这将使用SSL凭证

2. 为Kerberos凭据创建配置文件- 带有keytab的Kafka客户端配置，适用于生产者：

   KafkaClient { 需要com.sun.security.auth.module.Krb5LoginModule useKeyTab = true keyTab =“ / etc / security / keytabs / storm.service.keytab” storeKey = true useTicketCache = false serviceName =“ kafka” Principal =“ [e-mail]”; };

任何人都可以指导如何将其组合成可行的解决方案。

谢谢

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）