Предположим, у меня есть поток Кафки с окном Sessio, таким как: windowedBy(SessionWindows

Создайте SessionWindow из списка. Агрегированные входные данные. Ключ groupBy, сохраните...

У меня есть топология: Topology builder = new Topology(); builder.addSource("source"...

Есть ли способ использовать новый экземпляр компонента Autowired внутри агрегата Kafka Streams ??...

Это в качестве ссылки, поток обновлений профиля хранится в объекте KTable. Как долго эти данные...

Мы создаем приложение для получения данных с датчиков. Данные передаются в Kafka, откуда...

Я пытаюсь работать над архитектурой, управляемой событиями, используя Spring Cloud Stream и Apache...

Каков рекомендуемый подход для обработки исключения десериализации при использовании аннотации...

Я думаю сделать следующее. В Topic1 есть данные JSON Пример: {"name":"alice"...

Можно ли запросить KSQL KTable по ключу из отдельного приложения KStreams? Или, другими словами,...

У меня есть топология, в которой я использую Transformer для агрегирования своих объектов, позже в...

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

Можно ли настроить Kafka Streams для использования RockesDB-Cloud вместо базы данных RockesDB по...

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

Я пытаюсь реализовать поток Kafka, который обрабатывает сообщения о посещении веб-сайта...

Я настраиваю приложение Kafka Streams, которое использует тему (срок хранения: 14 дней, cleanup

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

У меня странная проблема, которую я не могу понять, как я могу решить. У меня есть приложение kafka...

Я строю топологию потоков kafka, в которой мне нужно материализовать содержимое Global KTable в...

Мы используем Kafka Streaming для нашей долгосрочной задачи потоковой передачи. Заданная нами...

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

Можно ли выполнить обработку потока kafka от определенного смещения входной темы до конечного...

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

Я хочу объединить журналы по идентификатору в пределах окна времени, используя Kafka Streams. На...

Я упрощаю свою проблему по следующему сценарию: 3 друга делят карту лояльности. Карта имеет два...