Обработка обновлений клиентов kafka в kubernetes

Question

У меня есть кластер Kafka, работающий в AWS MSK, с клиентами Kafka, работающими с производителем и потребителем, которые работают в kubernetes.Производитель отвечает за отправку потока данных в Kafka.Мне нужна помощь в решении следующих проблем:

1. Допустим, в коде производителя произошли некоторые изменения кода, и его необходимо повторно развернуть в kubernetes.Как я могу это сделать?Поскольку данные генерируются постоянно, я не могу просто остановить уже работающего производителя и развернуть обновленный.В этом случае я потеряю данные между процессами обновления.

2. Иногда из-за паники (golang) в коде клиент падает, но так как он работает как модуль, kubernetes перезапускает его.Я не могу понять, хорошо это или плохо.

Спасибо

Answer 1

Для вашего первого вопроса я бы предложил развернуть обновление вашего развертывания в кластере.Во-вторых, это общее поведение развертываний в kubernetes.Я мог бы подумать о решении для внешнего мониторинга, которое отменяет развертывание вашего приложения или останавливает обработку запросов в случае panic.Было бы лучше, если бы вы могли объяснить, почему именно вам нужно такое поведение!