apache-spark - Spark 与具有两个不同主体的 Kafka 交互

Question

我有以下问题。我正在使用 Spark Structured Streaming 作业，该作业从一个主题读取并写入同一 kerberized Kafka 集群的另一个主题。一切都超级好。

但我的问题如下：我将如何处理这两个主题中的每一个都有不同的主体和密钥表的情况。

• 我应该向 Spark 提交两个 JAAS 文件（每个主体/keytab 一个）吗？如果是，如何实现？
• 我可以将两个“KafkaClient”声明放入一个 JAAS 文件中吗？

非常感谢。