( Редактировать : небольшие правки для лучшего отражения намерения, но большие правки из-за...

KStream<String, dummy> demoZone = builder.stream(fromTopic, Consumed.with(Serializer

У меня агрегированное хранилище через DSL через оконную агрегацию через поток.Затем я получаю из...

Добавление конфигурации сжатия в Kafka Streams, аналогично этой ссылке : properties

У меня есть процессор, который берет строку json из темы с типом GenericRecord.Теперь я разделил...

Как вы используете хранилище состояний сессии с процессором API?Кажется, вам нужно знать конец окна...

Я не уверен, является ли kafka-streams правильным решением проблемы, которую я пытаюсь решить.Я...

У меня есть приложение kafka stream, работающее с 36 различными экземплярами (по одному для каждого...

У меня есть приложение Streams с GlobalKtable, поддерживаемым RocksDB, которое не работает

Я бы хотел помочь выбрать один из двух путей, которыми я могу следовать из тех, кто более опытен с...

Я пытаюсь использовать ConsumerRecordFactory, предоставленный Kafka Streams, следуя главным образом...

у нас есть приложение, которое нам нужно, чтобы сгруппировать миллионы событий в соответствии с...

Должен ли я использовать Kafka Consumer API или Kafka Streams API для этого варианта использования?...

Я читаю документы Filebeat Json по центральной теме. Фильтрация на основе источника / пути к файлу...

У меня есть ktable ktable ktable, связанный с темой, однако, когда сохранение сделано по теме,...

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

Я протестировал простой код, используя SessionWindows в Kafka Streams. (Версия Spring Cloud Stream:...

Я закрываю KafkaStream, когда мне нужно, основываясь на определенном условии: Закрытие:...

Я пытаюсь использовать KSQL для выполнения любой возможной обработки в течение определенного...

У меня есть процессор, и я хотел бы вызвать в нем context.forward (). Тем не менее, я чувствую, что...

Я работаю над приложением потоков Kafka, и у меня возникли проблемы с выяснением, как заставить...

Приведенный ниже код «работает», но я запутался в значении значений, передаваемых в Stores

Я хочу провести модульное тестирование агрегата Kafka Stream, и я совершенно не понимаю, какой...

Согласно документам, потоки будут помечены для перераспределения при применении map selectKey...

Я хочу провести сеанс с помощью (a,b), используя окна из потока, исходный ключ которого a, но он...