#java #spring #spring-boot #apache-kafka
#java #весна #весенняя загрузка #apache-kafka
Вопрос:
Я постараюсь задать неширокий вопрос:
У меня есть инфраструктура микросервисов в моем приложении. Я хочу собрать некоторые метрики в своем приложении. Некоторые из сервисов являются производителями, некоторые из них являются потребителями, а некоторые из них являются и тем, и другим.
Я хочу использовать Kafka, но раньше я этого не делал. Что я хочу сделать, так это:
- Некоторые производители отправят некоторые числа (например, 1)
- Сборщик метрик соберет эти числа
- Когда потребитель делает запрос, он получит среднее значение (или что-то еще) этих чисел
Я знаю, что могу использовать:
ProducerRecord<String, Integer>
Я использую Spring Boot и могу использовать его текущую интеграцию:
или собственная реализация Kafka.