Service Mesh на стероидах, часть 2: Zero Deployment Downtime в корпоративных приложениях

[dph]

Спасибо за статью!

Пока еще не понятно, как именно работает фильтр на kafka-consumer.
Вот у меня consumer из активного поколения (g4), из топика пришло сообщение с g3. По идее, должно быть два сценария:
1) если есть где-то еще консьюмер из legacy-поколения g3, то нужно игнорировать это сообщение.
2) если нет консьюмеров из legacy-поколений, то нужно его попробовать обработать.

Но для этого каждый консьюмер должен знать про всех других консьюмеров (и синхронно). Как это реализуется?
Или это тема следующей статьи?

[ggo]

это избыточно. надо обеспечить синхронность настроек сеттера поколений и консьюмеров, ориентирующихся на поколения. плюс мониторинг зависших сообщений в кафке.

[dph]

Что значит "избыточно"? Как именно избегаем проблемы получения в консьюмере из g4 сообщения из g3?
И в кафке не бывает "зависших сообщений", что имеется в виду?