Искровой потоковый коммутатор Kafka Cluster без перезапуска
У меня есть два кластера kafka, оба имеют все темы и данные. Когда один кластер kafka вышел из строя, я хочу перенаправить на другой кластер kafka, но как работа потоковой передачи искры работает правильно с преобразованием смещения потребителя. Каждая задача имеет фиксированный ввод KafkaRDD (тема, раздел, startOffset, endOffset), может ли инициировать плавное переключение потокового задания с одного кластера kafka на другой кластер kafka и использовать преобразованное смещение без перезапуска всего задания spark?