Kafka Streams — это библиотека для обработки потоков данных в реальном времени поверх Apache Kafka. Она позволяет создавать приложения, которые читают, обрабатывают и записывают данные в Kafka топики с минимальной задержкой.

Применяется для:

Агрегации и фильтрации событий в реальном времени.
Обогащения данных, объединения нескольких потоков.
Реализации сложной логики обработки событий без необходимости писать отдельные сервисы.

Например, в проекте я использовал Kafka Streams для подсчёта количества кликов по разным категориям товаров в реальном времени, чтобы обновлять статистику на сайте без задержек.

Что такое Kafka Streams и для чего применяли?