#apache-spark #apache-kafka #spark-streaming-kafka
#apache-spark #apache-kafka #потоковая передача spark-kafka
Вопрос:
У меня следующий вопрос. Я использую структурированное потоковое задание Spark, которое считывает данные из одной темы и записывает в другую тему того же кластера Kafka с использованием kerberized. Все работает супер.
Но моя проблема заключается в следующем: как бы я справился со случаем, в котором у меня для каждой из этих 2 тем разные участники и keytab.
- Должен ли я отправить два файла JAAS (по одному для каждого участника / keytab) в Spark? Если да, то как этого можно достичь?
- Могу ли я поместить оба объявления «KafkaClient» в один файл JAAS?
Большое вам спасибо.