Я пытаюсь определить варианты использования потребителей Kafka в капсулах kubernetes. По сути, у меня есть служба, которая работает в kubernetes и использует данные в памяти, любое обновление, необходимое для данных, будет опубликовано в топике Kafka c внешним агентом, и мне нужен потребитель, чтобы подписаться на эту топи c и обновить данные в памяти в каждом модуле для этой службы (контейнер, запущенный в каждом модуле для этой службы, имеет HTTP API для обновления данных в памяти) - я думаю о том, чтобы в каждом из них работал потребитель kafka модели коляски pod и обновите экземпляр службы. Вопросы:
- Кто-нибудь уже сделал такой сценарий?
- Как создать потребителя кафки в качестве коляски в модуле, который слушает четко определенные топи c в KAFKA?.
Я пытался найти Как идентифицировать все модули для служб и pu sh обновления непосредственно (от общего потребителя KAFKA) до экземпляра в каждом модуле для этой службы как хорошо - без использования потребителя кафки в каждой капсуле, но я думал, что использование потребителя в каждой капсуле может быть лучшим решением.