Я хотел бы создать магазин StoreBuilder[KeyValueStore[String, TimedGenericRecord]] с case class...
Мы увеличили количество разделов для параллельной обработки сообщений, поскольку пропускная...
Я использую Kafka Streams для некоторых агрегатов TimeWindow.Меня интересует только конечный...
Наше приложение периодически встречает исключение OutOfOrderSequenceException в нашем коде потоков
У меня возник вопрос при прохождении через это удивительное руководство https://kafka.apache
У меня есть тема, в которую поступает поток данных.Мне нужно создать отдельную тему из этой темы,...
Я реализовал простой процессор записи мертвых букв Kafka. Он отлично работает при использовании...
Я использую debezium для сбора изменений из 4 таблиц из моей БД книжного магазина, модель данных -...
Я пытаюсь выполнить операцию подсчета на KStream и сталкиваюсь с некоторыми трудностями в понимании...
Показатели общего процесса мне не понятны.Метрика задокументирована как «Общее количество вызовов...
Насколько я знаю, Kafka Streams обрабатывает свои состояния локально в памяти, на диске или в теме...
Можем ли мы сгруппировать по двум полям (одно является ключом, а другое значение) и получить...
Мы заметили в журналах нашего брокера kafka, что наши потоковые приложения пытаются описать темы,...
Есть ли способ получить идентификатор клиента в процессоре?Я думаю, что это может быть возможно с...
KGroupedTable.count () возвращает отрицательные значения? idAndJobTransaction .filter((k,v) -> v
Мы пытаемся создать сервис дедупликации, используя Kafka Streams.Общая картина состоит в том, что...
Кафка Streams внутренне вычисляет водяные знаки?Можно ли наблюдать результат окна (только), когда...
У меня есть случай, когда каждую секунду 5k сообщений отправляются в тему kafka. На стороне...
Я знаю, что могу получить доступ к метрикам через KafkaStreams :: metrics ().Однако можно ли в...
У меня проблема с потребителями восстановления, они не могут подключиться к посредникам, получая:...
Я новичок в Kafka и пытаюсь построить конвейер для моих журналов apache httpd на mongodb. У меня...
У меня есть топология Kafka Streams, в которой хранилище сеансов создается посредством агрегации...
Я сталкивался с тремя популярными потоковыми техниками, такими как Spark Streaming, Structured...
kafka-streams создает множество неявных тем в зависимости от топологии нашего kafka-stream. В...
Я пытаюсь присоединиться к KStream с KTable.Без объединения у меня нет проблем с чтением из...