Перезапуск кластера Kafka через ansible

Question

Каков рекомендуемый способ перезапустить все серверы kafka, которые являются частью кластера?

Природа вопроса связана с тем, что мы управляем им через ansible, и у нас есть notify относительно изменений, касающихся например server.properties, поэтому перезапуск происходит одновременно.

Обычно, когда исчезает брокер, происходит перебалансировка данных, поэтому мне интересно, что произойдет, если все брокеры будут перезагружены одновременно .

Answer 1

разумным образом перезапустить приложение. c. Чтобы это работало, вам нужно собрать требования:

• Что лучше - один перезапуск без возможности перезапуска (не более одного раза) или гарантированный перезапуск с возможностью многократного перезапуска (хотя бы один раз)
• Как определить, можно ли перезапустить узел?

В зависимости от первого вопроса вы можете использовать флаги файлов (в / tmp), чтобы указать, что перезапуск ожидает (и используйте этот флаг в качестве постоянного хранилища для перезапуска приложения, если в середине воспроизведения не удалось воспроизвести книгу).

Для второго вопроса лучше всего запросить что-то вне Ansible (например, какой-нибудь сервер API, сервер мониторинга и т. д. * 1017). *) чтобы узнать, разрешен ли перезапуск.

Самый безопасный и медленный подход - запустить перезапуск playbook с serial: 1 и несколько проверок перед перезапуском узла.