次の質問があります。あるトピックから読み取り、同じ kerberized Kafka クラスターの別のトピックに書き込む Spark 構造化ストリーミング ジョブを使用しています。すべてがうまく機能します。
しかし、私の問題は次のとおりです。これら 2 つのトピックのそれぞれに異なるプリンシパルとキータブがある場合、どのように処理すればよいでしょうか。
- 2 つの JAAS ファイル (プリンシパル/キータブごとに 1 つ) を Spark に送信する必要がありますか? はいの場合、これはどのように達成できますか?
- 両方の「KafkaClient」宣言を 1 つの JAAS ファイルに入れることはできますか?
どうもありがとうございました。