опытом, если применяли, для чего и как результат?
Kafka streams топ.
Один из примеров, реалтайм обработка миллиардов сообщений в сутки на лету (аггрегация и трансформация данных).
Тот же пример, только данных заметно меньше
Применял, применяю и буду применять. Применения разные: - обогащение (думаю, самый стандартный кейс) - то есть join на лету - фильтрация и сигналинг - когда есть вечный топик, а часть сообщений из него надо складывать в короткоживущий топик (например, есть ES-поток изменений агрегата "Заказ", но момент закрытия заказа складывается в топик с другим retention policy - для нотификаций, например) - трансформация схемы (есть старый топик со старой схемой и новый - с новой схемой) - агрегация чего-то "на лету", включая вычисление средних и прочих статистических характеристик по sliding window, очень полезно для всякой аналитики. Ну и конечно всевозможные комбинации этого. API там прекрасный и документация отличная. Даже те, кто Java владеет поверхностно (типа "учили в универе, на практике не применял") осваивают очень быстро, там больше всё-таки нужно думать о топологии процессинга.
Большое спасибо, уважаемые коллеги, за подробные ответы. Есть повод вникнуть в тему более основательно)
Обсуждают сегодня