Как я понимаю, Apache Spark Master можно запустить в режиме высокой доступности с помощью Zookeeper. То есть несколько мастеров Spark могут работать в режиме Лидер / Подписчик, и эти режимы зарегистрированы в ZooKeeper.
В нашем сценарии ZooKeeper истекает сессия Spark Master, которая действует как Лидер. Поэтому Повелитель Искр, являющийся лидером, получает это уведомление и намеренно отключается.
Может кто-нибудь объяснить, почему было принято это решение о закрытии, а не повторной попытке?
И почему Кафка повторяет подключение к Zookeeper, когда получает такое же уведомление об истечении срока действия?