Этот вопрос относится к представлениям агрегации KSQL или технологии потоковой обработки.Когда мы...
Я новичок в потоковом процессоре kafka и натолкнулся на ключевую концепцию "топологии". Я создал...
Я использую библиотеку Kafka Stream для потокового приложения.Я хотел установить идентификатор...
В пользовательском Transformer мы пытаемся создать и переслать некоторые записи в методе init(..)....
Я пытаюсь использовать потоки Кафки, чтобы выполнить оконную агрегацию и выдать результат только...
Я хочу создать интерактивные условия для своего потока kafka.Я просто хочу знать, возможно ли это....
Я ищу способ сделать инструмент повторной обработки в KafkaStreams, который позволит повторно...
У нас есть экземпляр kafka с примерно 50M записями, с входом около 100k в день, так что в мире...
Есть ли способ, которым рабочая группа может запретить командам приложений создавать промежуточные...
Наше потоковое приложение kafka продолжает открывать новые файловые дескрипторы, пока они являются...
Я новичок в потоках kafka и хотел бы прочитать тему и написать ее часть в новой теме, используя...
Допустим, у меня есть поток событий. R1 - {"abc": "значение 1"} R2 - {"abc": "значение 2"} R3 -...
Что происходит в приложении KafkaStreams, если ему не удается зафиксировать смещение из-за...
У меня есть следующий код .Моя цель - сгруппировать сообщения по заданному ключу и 10-секундному...
При построении топологии Kafka Streams чтения из нескольких тем можно моделировать двумя различными...
Вариант использования: учетная запись A отправляет 500 баксов на учетную запись B, мы используем...
Я хотел бы знать, сколько времени занимает каждая запись в обработке потоков?Поэтому, когда я...
Я пытаюсь настроить топологию для изменения каталога по умолчанию, в котором хранятся хранилища...
У меня проблема с использованием соединений kstream.Что я делаю, это из одной темы, я разделяю 3...
В настоящее время я делаю POC потоков kafka, в котором я пытаюсь использовать kakfa как шину обмена...
Я не уверен, что он уже ответил. Поскольку я не получил надлежащего объяснения, отправляю свой...
Мое требование заключается в том, чтобы я получил файл JSON из раздела Kafka в Kafka Stream, из...
У меня есть сценарий, в котором я создаю Kafka KStream, читая данные из темы kafka.Записи KStream...
Допустим, я хочу написать модульный тест для показанного здесь примера: https://github
На моем затмении я запускаю простую программу Kafka Streams, которая успешно работает, но она не...