__ consumer_offsets хранит смещения всех тем kafka, кроме внутренних тем, таких как темы *...
После прослушивания темы kafka с использованием @StreamListener, при RuntimeException, глобальном...
У меня есть сервис, который вызывает дюжину других сервисов.Это читает тему Кафки, используя...
"представления ведут себя как форма постоянно обновляемого кэша"? Является ли это средним...
Я изучаю потоки кафки и написал простое приложение, фрагмент которого приведен ниже: MainApp:...
Кафка внутренне уничтожит все узлы, которые неправильно опрашивают, но мы не хотим, чтобы плохие...
Я сталкиваюсь с проблемой присоединения KStream к GlobalKTable и буду признателен за вашу помощь....
В одном из приложений наш клиент получает несколько событий в файлах, загруженных на FTP-сервер....
У меня есть следующее //Config setup Properties props = ...; //setup List<String> topicList =...
Я пишу приложение, которое обрабатывает входящую запись координат и отслеживает их на вход или...
Мне интересно, почему в Kafka Stream API отсутствует неблокирующая поддержка с помощью простых...
Вот пример KTable, который я построил и который представляет собой простую агрегацию: String name =...
Если у меня есть потоковое приложение Kafka, которое не может опубликовать в теме (поскольку тема...
Я хотел бы использовать событие из темы Кафки, добавить его в базу данных, выполнить несколько...
Я пытаюсь понять kafka stream processor немного больше. Я хочу знать, что такое frequency of...
Мне нужно отправить предупреждение, если в теме не было получено ни одного события в течение...
Я пытаюсь понять поведение RocksDB в API процессора потоков Кафки. Я настраиваю постоянный...
Мой код в настоящее время использует InMemoryKeyValueStore, что позволяет избежать сохранения на...
У меня проблема с агрегацией KStreams и окнами. Я хочу объединить запись в список записей, которые...
В KafkaStream при реализации ValueTransformer или ValueTransformerWithKey при вызове transform () я...
Я пытаюсь отправить список [KeyValue] в тему в приложении Kafka Streams.Но поток ожидает...
Запуск приложения Stream (с использованием Kafka Streams) завершается с ошибкой «java.lang
Построение потокового приложения с использованием kafka stream. У меня есть тема с 8 разделами, где...
Я заметил, что стадия aggregate(), кажется, сериализует / десериализует каждый отдельный элемент,...
Мы разрабатываем приложение Kafka Streams, используя низкоуровневый процессорный API. Согласно...