Ссылаясь на это решение , файл My spring-cloud-stream application.yml имеет следующую конфигурацию:...

У меня есть топология, где у меня есть поток A. Из этого потока A я создаю WindowedStore S. A...

Используя преобразования одиночного сообщения (SMT), например, InsertField Transformation, можно...

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

При развертывании Confluent-Replicator с версией 5.1.2 выдает ошибку ниже: org.apache.kafka.common

Когда я имитирую случай подсчета слов с использованием функции агрегирования, я сталкиваюсь с...

Приложение работает на IntelliJ с локальным режимом Spark. В цикле, когда тема Consumer from Kafka...

Работа с версией kafka: 2.0.1 & kafka-streams-scala версия 2.0.1 Регистрация сообщений отладки,...

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

Я запускаю задание структурированной потоковой передачи в приемник MongoDB, и я сталкиваюсь с...

AWS Kinesis предлагает реализацию управления потоковыми окнами, которая помогает «анализировать...

Я использую kafka-streams 2.0.1 в контексте Spring Boot 2.1.4. CONSUMER-ID имеет следующий шаблон...

Я запускаю структурированную потоковую передачу на Spark 2.3 на Cloudera с Kerberized Confluent...

У меня есть DStream[RawWeatherData] объект с именем parsedWeatherStream. Каждый объект в...

Я использую Kafka 1.1 и Kafka Rest Proxy 4.1.2. Я копировал записи из потоков Кафки, используя...

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

У меня есть приложение Kafka Streams, где я присоединяюсь к KStream, который читает из «topic1», с...

Допустим, я использую потоки kafka (библиотека kafka-streams-scala, версия 2.2.0). Мне нужно...

В моей локальной системе работает брокер kafka.Чтобы общаться с неработающими с помощью моего...

Существует ли существующее программное обеспечение для готового к работе распределенного журнала с...

Я использую Kafka Streams с одной 5-секционной темой ввода ("input_topic"), но у меня много...

Я экспериментирую с OGG BD (v12.3.2.1.1), чтобы распространить все изменения из базы данных Oracle...

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

Я получаю сообщения json из потока kafka. Я хочу создать основанное на этом окне время и принять...

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