У меня есть вопрос о TimeWindows с Kafka Streams, некоторые концепции меня действительно смущают. У...
Я знаю, используя API-интерфейсы потребителей Kafka, мы можем получить смещение, соответствующее...
У меня сложная топология, включающая в себя KStreams, KTables, объединения, повторное использование...
Я пытался запустить простое приложение для подсчета слов, используя Kafka, однако всякий раз, когда...
Это продолжение Чтение из ВСЕХ разделов в каждом экземпляре приложения Что я пытаюсь достичь, это...
У меня проблемы с объединением двух потоков кафки, извлекающих дату из полей моего события
Я пытаюсь запустить новый проект SBT Scala и получить в файле build.sbt следующее: name :=...
Мы создаем высокопроизводительное приложение для обработки потоков с низкой задержкой.Мы используем...
Нашей целью является достижение следующей архитектуры.И самое главное - иметь возможность прочитать...
Я создал шаблон scala g8 для kafka streams, но заметил, что он печатается только когда приложение...
При использовании KTable потоки Kafka не позволяют экземплярам читать из нескольких разделов...
В приложении Kafka Streams у нас есть KTable (не KStream), в котором мы хотим вычислить некоторую...
!! Тестовая среда Производитель, отправляющий сообщение с ключом 'A' раз в секунду. Kafka Streams...
Я пытаюсь выполнить некоторые тесты для Kafka с использованием Kstreams и KTable. Kafka KTables -...
Я хочу реализовать механизм зеркалирования между брокерами kafka и найти потоки kafka как хорошее...
Информация, которую я ищу, - это HostInfo экземпляра streams, в котором хранится сохраненный ключ,...
У меня есть тема, где публикуются события о файлах.По этой теме создается группировка с таблицей с...
Я использую поток kafka для агрегирования данных и записи в другую тему. Каждые несколько минут...
У меня есть хранилище состояний в памяти, которое я открываю через интерактивный API Queries + Rest
На прошлой неделе я задал этот вопрос: KSQL: добавить несколько дочерних записей в родительскую...
Я хочу провести анализ поведения пользователя на событиях в Кафке.Может ли KSQL / Kafka Streams...
Приложение My Kafka Streams использует тему kafka, которая использует следующую раскладку...
Есть ли GlobalKTable (в DSL API) эквивалент в API Kafka Streams Processor, т.е. есть ли способ...
Я хотел бы создать приложение на основе потока Kafka, которое обрабатывает тему и принимает...