У нас есть Java-сервис на основе rest-api (приложение Spring REST на сервере Tomcat), который в основном обрабатывает операцию CRUD с базой данных. Теперь у нас есть требование использовать некоторые события Kafka для обновления нескольких таблиц.
Хороша ли практика держать потребителей Kafka внутри Java-приложения на основе API rest (или) можем ли мы иметь выделенный сервис, который обрабатывает события kafka.
Запросы:
1). Если мы включим этих потребителей в приложение для отдыха, как потребители Kafka будут вести себя вместе с API для отдыха. например, если есть запрос, полученный от вызова rest API, и в то же время событие Kafka доступно для использования (или) уже находится в обработке.
2). Если у нас есть потребитель Kafka внутри приложения rest api, как мы можем корректно развернуть / развернуть изменения кода. Учитывая, что в приложении rest мы можем истощить соединение с контейнерами из балансировщиков нагрузки, одновременно отключая их.
Подробнее здесь: https://stackoverflow.com/questions/786 ... pplication
