Потоковая передача нескольких тем Kafka одновременно с использованием Spark

Я использую Spark версии 2.1, и мне нужно передавать данные одновременно из нескольких тем Kafka. Я старался spark.streaming.concurrentJobs чтобы добиться этого, но это не работает. Я создал логику обработки в целом. Есть ли другой способ добиться этого?

0 ответов

Другие вопросы по тегам