AWS Kinesis предлагает реализацию управления потоковыми окнами, которая помогает «анализировать...

Я использую kafka-streams 2.0.1 в контексте Spring Boot 2.1.4. CONSUMER-ID имеет следующий шаблон...

Я использую Kafka 1.1 и Kafka Rest Proxy 4.1.2. Я копировал записи из потоков Кафки, используя...

У меня есть 3 источника данных, которые предоставляют API для доступа к ним, каждый из них...

У меня есть два потока данных, поступающих в кластер Kafka.Я хочу обработать эти данные с потоками...

У меня есть приложение Kafka Streams, где я присоединяюсь к KStream, который читает из «topic1», с...

Следуя совету здесь , я пытаюсь использовать встроенный Kafka для тестирования моего приложения...

Допустим, я использую потоки kafka (библиотека kafka-streams-scala, версия 2.2.0). Мне нужно...

Я использую Kafka Streams с одной 5-секционной темой ввода ("input_topic"), но у меня много...

Я унаследовал этот код и не могу понять, почему он не работает.Это должно работать, но, очевидно,...

Допустим, у меня есть 2 потока kafka (библиотека kafka-streams-scala, версия 2.2.0): val builder:...

Вот что я пытаюсь сделать: Я пытаюсь использовать сообщения в 5-минутном временном окне и...

Я написал простой пример для проверки функциональности соединения.Поскольку я иногда получаю...

Можно ли использовать интерактивный запрос (InteractiveQueryService) в Spring Cloud Stream для...

У меня есть приложение KStream с кучей KStreams, объединений и других операций. Я включил logging

Я использую Kafka Streams с Tumbling Window с последующим шагом агрегирования. Но наблюдение за...

Я ищу ожидаемое поведение при перемещении хранилища состояний существующего приложения потоков в...

У меня есть функция потока KStream<K, V>[] branch(final Predicate<? super K, ? super V>

У меня есть данные, которые слишком велики для одного сообщения.Рассмотрим avro: record Likes {...}...

Я локально запускаю приложение (Spring Boot и Spring Cloud Stream, Kafka Binder и Kafka Streams...

Я работаю над сценарием использования, в котором я создал конвейер, который отправляет данные из...

Я пытаюсь создать самый простой мир привет с помощью Spring Cloud + Kafka Streams + Spring Boot 2....

Я реализовал свой собственный Transformer, где я накапливаю события в моем StateStore (во...

Я перешел по официальной ссылке , но не получил точно одно окончательное окно окончательных...

Я бы хотел настроить стратегию именования субъектов схемы Avro в источниках, потребителях и...