Как определить, когда материализация KTable в теме завершена? Например, предположим, что KTable...
Во всем примере я вижу простую топологию с одним преобразователем / процессором для Kafka.Я...
Я не получаю такую большую пропускную способность, как мне кажется, с моим приложением this...
У меня есть 2 потока с именами «тревога» и «вмешательство», которые содержат JSON.Если тревога и...
Я готовлю приложение Kafka Stream с Java.Задача использует некоторые сообщения из темы, которая...
Я создаю приложение для электронной коммерции, в котором в настоящее время я работаю с двумя...
Я создал материализованное представление в потоке kafka, я не могу найти фрагмент кода Java для...
Я играю с Kafka Streams и столкнулся с ситуацией, которая кажется мне немного странной. Я искал по...
Можно ли определить serialVersionUID в классе, который расширяет интерфейс Serializer /...
Мы недавно обновили нашу версию kafka с 0.10 до 1.0, и я обновляю устаревший код KTable<Long,...
Какой класс / метод в Kafka Streams мы можем использовать для сериализации / десериализации...
Я пытаюсь использовать хранилище состояний для дедупликации сообщений, полученных топологией...
Я создаю данные из одной темы А в другую Б, используя потоки. Но это очень медленно.В теме A есть...
У меня есть объект потока kafka, подобный этому: [KSTREAM-SOURCE-0000000000]: null,...
Справочная информация: я использовал неправильный реестр схемы avro при создании темы prod, и в...
У меня есть следующая конфигурация для моего приложения Kafka Stream Properties config = new...
Определен пользовательский магазин, для использования в пользовательском Transformer (ссылка ниже)....
У меня есть Processor-API Processor, который внутренне перенаправляет в несколько отдельных...
Данные, получаемые из потока, должны агрегироваться на дневном и месячном уровне. С учетом...
Могу ли я использовать преобразование без состояния, даже если это означает изменение ключа на...
Если мы запустим приложение KafkaStream в фоновом режиме (скажем, в Linux), есть ли способ передать...
С гарантией, по крайней мере, один раз, я понимаю, что существует возможность дублирования в случае...
Есть ли способ настроить расписание, при котором данные в KTable должны сохраняться (.to ()) в теме
В рамках нашей логики приложения мы используем хранилище состояний Kafka Streams для поиска range ,...
Я работаю над потоками Кафки, используя приведенный ниже код.Я проверяю условие фильтра из объекта...