Как зарегистрировать процессор без сохранения состояния (который, кажется, также требует StateStore)?

Распечатать Кафка Стрим Вводить на консоль?

Я просматривал много документации Kafka для Java-приложения, над которым я работаю. Я попытался войти в лямбда-синтаксис, представленный в Java 8, но я немно...

Кафка - проблемы с TimestampExtractor

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

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

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

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

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

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

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

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

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

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

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

новеApache Kafka Docs