Блог

Я постараюсь задать неширокий вопрос:

У меня есть инфраструктура микросервисов в моем приложении. Я хочу собрать некоторые метрики в своем приложении. Некоторые из сервисов являются производителями, некоторые из них являются потребителями, а некоторые из них являются и тем, и другим.

Я хочу использовать Kafka, но раньше я этого не делал. Что я хочу сделать, так это:

1. Некоторые производители отправят некоторые числа (например, 1)
2. Сборщик метрик соберет эти числа
3. Когда потребитель делает запрос, он получит среднее значение (или что-то еще) этих чисел

Я знаю, что могу использовать:

 ProducerRecord<String, Integer>
 

Я использую Spring Boot и могу использовать его текущую интеграцию:

https://spring.io/blog/2015/04/15/using-apache-kafka-for-integration-and-data-processing-pipelines-with-spring

или собственная реализация Kafka.