Проще говоря, я хочу вычислять низкую и высокую температуру за каждую минуту (окно...

Javadocs KStream / TopicNameExtractor указывают, что при использовании to(TopicNameExctractor...

Примеры приложений для проверки этого можно найти в https://github

Мое требование - пропустить или избежать дублирования сообщений (имеющих одинаковый ключ),...

Когда я включаю ровно одну обработку, я получаю следующую ошибку. ПРИМЕЧАНИЕ. Наши приложения очень...

У меня есть приложение (spring-boot-shipping-service) с KStream, которое получает сообщения...

В моем приложении Java у меня есть процессор Kafka. Мой метод процесса выглядит так: @Override...

Я использую Kafka Streams для чтения из темы в моем кластере и хочу фильтровать сообщения на основе...

Я хотел бы использовать как Processor API, так и DSL в одном приложении потоков Kafka. Кроме того,...

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

У меня высокоскоростная конечная точка с определенной полезной нагрузкой. В очереди 800 активных...

Я использую Spring Cloud Finchley.RELEASE с RocksDb и Kafka-Streams для производственного...

У меня есть вопрос с потоковой передачей в целом, но для целей вопроса давайте ограничимся Kafka...

Предположим, что приложение Spring Cloud Stream создает KStream из order topic.Интересует...

я создаю приложение spring-cloud-streams, в котором вывод имеет вид AVRO, мне удалось заставить его...

Мне нужно использовать API Kafka Sreams вместе с процессором API. Я также хочу написать различные...

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

Проблема: Как объединить поток, созданный из TOPIC_2 (на шаге 2), в таблицу состояний KTable (на...

Это мое приложение, которое просто получает ссылку на KStream из темы клиента (привязка ввода) и...

Я хочу перезаписать GlobalKTable (возможно, при его инициализации, поскольку я считаю, что они...

У меня есть две темы, одна с 3 разделами и одна с 48. Первоначально я использовал назначитель по...

Я использую поток Кафки для некоторых приложений. Поток потока, как показано ниже...

в StreamsConfig есть параметр STATE_CLEANUP_DELAY_MS_CONFIG, который говорит: «Количество времени в...

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

У меня есть работающее приложение Kafka Streams, которое в настоящее время создает два KStreams из...