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