Я пытаюсь написать простое приложение Kafka Streams (нацеленное на Kafka 2.2 / Confluent 5.2),...

Пример, который я пытаюсь выяснить, следующий: У нас есть три типа событий. School_Created -...

У меня есть приложение Kafka Streams (Kafka Streams 2.1 + Kafka broker 2.0), которое выполняет...

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

Я использую подавление в падающих окнах для получения агрегированных результатов. Я изучаю оба...

У меня есть требование присоединиться к 3 темам Кафки. Первые две темы A и B будут добавлены с...

Я работаю над управлением окнами потоков kafka, в частности, окнами для моего варианта...

У меня проблемы с попыткой добиться следующего через Kafka Streams: При запуске приложения (сжатая)...

Я хочу материализовать KTable из KStream и хочу, чтобы KeyValueStore сортировался по Key. Я...

Мне нужно собрать некоторые данные датчиков, и я экспериментирую с оконным агрегированием для PoC /...

Какую стратегию разделения использует поток Kafka?Можем ли мы изменить стратегию разделения в Kafka...

При получении вывода из потока kafka logstash также отображает другие символы.(\ u0018, \ u0000, \...

Невозможно десериализовать avro GenericData в облачных потоках Spring KStreams. В моем продюсере я...

Я использую kafka-streams, и использование памяти вне кучи возрастает до физических ограничений...

Передача состояния, переносимого событием, устраняет необходимость совершать удаленные вызовы для...

Мое приложение kafka streams работает нормально, когда я нахожусь в среде, где мой коэффициент...

Мы используем Ktabke для агрегирования в kafka, его очень простое использование и ссылаемся на...

Я использую Spring-Cloud-Starter-Stream-Kafka - 1.3.3 и Spring-Cloud-Stream с Spring Boot для...

Я хочу использовать Kafka Streams Processor API и генерировать некоторые сообщения каждую минуту в...

, когда я пытаюсь получить доступ к стерео состояния из потока, я получаю ошибку ниже, Хранилище...

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

По какой-то причине мои старые государственные хранилища не очищаются после истечения срока...

Пытаясь получить доступ ко всем значениям ключа в определенном хранилище состояний, но в методе

Я пытаюсь провести некоторое тестирование с использованием EmbeddedKafkaCluster из библиотеки...

Давайте предположим упрощенный сценарий, подобный этому: Есть две темы Кафки , пользователи и...