1. Обзор
В этой статье мы рассмотрим библиотеку KafkaStreams
.
KafkaStreams
разработан создателями Apache Kafka .
Основная цель этой части программного обеспечения — позволить программистам создавать эффективные потоковые приложения в режиме реального времени, которые могут работать как микросервисы.
KafkaStreams
позволяет нам получать из тем Kafka, анализировать или преобразовывать данные и, возможно, отправлять их в другую тему Kafka.
Чтобы продемонстрировать KafkaStreams,
мы создадим простое приложение, которое читает предложения из темы, подсчитывает вхождения слов и печатает количество слов.
Важно отметить, что библиотека KafkaStreams
не является реактивной и не поддерживает асинхронные операции и обработку обратного давления.