Результаты поиска по запросу "apache-kafka-streams"
Как отфильтровать ключи и значения с помощью процессора, используя Kafka Stream DSL
У меня есть процессор, который взаимодействует с StateStore для фильтрации и выполнения сложной логики сообщений. в
Кафка потокового параллелизма?
У меня есть некоторый базовый код Kafka Streaming, который читает записи из одной темы, выполняет некоторую обработку и выводит записи в другую тему.Как пото...
использование двух или более кластеров Kafka в приложении Kafka Streams является одним из отличий между Kafka Streams и Spark Structured Streaming (поскольку последний может использовать столько кластеров Kafka, сколько вы хотите, и, таким образом, вы можете строить конвейеры между различными кластерами Kafka) ,
оводство разработчика Kafka Streamsэто говорит: [https://docs.confluent.io/current/streams/developer-guide/config-streams.html] Приложения Kafka Streams могут взаимодействовать только с одним кластером Kafka, указанным в этом значении ...
Как добавить пользовательский StateStore к процессору Kafka Streams DSL?
Для одного из моих потоковых приложений Kafka мне нужно использовать функции как DSL, так и Processor API. Мой поток потокового приложения
будет нарушен. Я понимаю, что это может быть неуклюжим в сценарии тестирования, однако в реальном развертывании это потоковая обработка и, следовательно, никаких проблем.
исал этот код в потоковом приложении Kafka: KGroupedStream<String, foo> groupedStream = stream.groupByKey(); groupedStream.windowedBy( SessionWindows.with(Duration.ofSeconds(3)).grace(Duration.ofSeconds(3))) .aggregate(() -> {...}) ...
Кафка многораздельного заказа
Мне известно, что в Kafka невозможно заказать несколько разделов и что порядок разделов гарантирован только для одного потребителя в группе (для одного разде...
Каждая запись будет отправлена каждому предикату один раз - это концептуально широковещательная рассылка всем фильтрам, но записи не будут физически реплицированы, поэтому нет никаких накладных расходов памяти.
я есть одна основная тема и несколько предикатов, с каждым из которых связана выходная тема. Я хочу отправить каждую запись во ВСЕ темы, чей предикат разреша...
Извините - не уверен, куда это поставить - я не парень из потоков; Я просто взломал ваши материалы, чтобы исключить встроенного брокера (так как это в вашем названии вопроса). Рад попробовать для вас, если вы можете быть более откровенным с тем, что вы хотите, чтобы я сделал. Но это будет завтра; поздно.
хожу в поисках знания тайного. Во-первых, у меня есть две пары тем, по одной теме в каждой паре, которая входит в другую тему. Два KTables формируются последними темами, которые используются в KTable + KTable leftJoin. Проблема в том, что ...
Я прочитал это, и он поднял хорошие моменты. Однако они не применимы к описанной мной схеме, в которой используются потоки Kafka: загрузка текущего состояния - выполняется с использованием KTable; Последовательные записи - это дескрипторы модели разделов Кафки и гарантии отказоустойчивости
аюсь реализовать простое подтверждение концепции CQRS / источников событий поверхПотоки Кафки [https://kafka.apache.org/documentation/streams/](как ...
, Обратите внимание, что это всего лишь «запрос к потокам» для фиксации как можно скорее - это не выдача фиксации напрямую.
ли способ сделать коммит вручную с Kafka Stream?Обычно с использованием