): Таким образом, с точки зрения потребителя, с точки зрения потребителя, мы используем фиксацию вручную, однако, с точки зрения Kafka Streams, она все еще выполняется автоматически, и нет конфигурации Kafka Streams для ее отключения.

afka Streams, если мы используем низкоуровневый процессор API, мы можем контролировать фиксацию или нет. Так что, если в нашем коде возникают проблемы, и мы ...

Windows, но я также проверил его на Linux, и он работал.

способ протестировать приложение Kafka Streams. Чтобы я мог определить входные события, а набор тестов показывает мне вывод.Это возможно без реальной настрой...

issues.apache.org/jira/browse/KAFKA-4936

ли в Kafka Streams функциональность, позволяющая динамически соединять один входной поток с несколькими выходными потоками?

Вот ключевая часть приведенного выше примера кода (опять же для Kafka 0.10.1), немного адаптированная к вашему вопросу. Обратите внимание, что этот пример демонстрирует OUTER JOIN.

новеApache Kafka Docs

Как отфильтровать ключи и значения с помощью процессора, используя Kafka Stream DSL

У меня есть процессор, который взаимодействует с StateStore для фильтрации и выполнения сложной логики сообщений. в

Как я могу получить значение смещения в KStream

Как добавить пользовательский StateStore к процессору Kafka Streams DSL?

Для одного из моих потоковых приложений Kafka мне нужно использовать функции как DSL, так и Processor API. Мой поток потокового приложения

Почему Apache Kafka Streams использует RocksDB и как это можно изменить?

Кафка потокового параллелизма?

У меня есть некоторый базовый код Kafka Streaming, который читает записи из одной темы, выполняет некоторую обработку и выводит записи в другую тему.Как пото...

Кафка многораздельного заказа

Мне известно, что в Kafka невозможно заказать несколько разделов и что порядок разделов гарантирован только для одного потребителя в группе (для одного разде...