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

У меня возникли проблемы с использованием метода KStream through(), чтобы гарантировать, что...

Мы используем концентраторы событий Azure с опцией интеграции Kafka.Наши услуги на Java, Spring...

Мы используем установку брокера kafka с приложением потоков kafka, которое работает с...

Допустим, я использую API процессора Kafka Streams для написания очень простого процессора, который...

Я хочу интегрировать Apache Kafka и Spark Streaming, я использую spark-streaming-kafka-0-8_2.11, я...

Есть ли способ с постоянным хранилищем состояний разрешить истечение срока действия ключей в...

У нас есть приложение kafka streams (2.0), которое взаимодействует с брокерами kafka (1.1.0)

Я использую spark 2.3.1 и kafka 0.10 с приведенными ниже зависимостями: kafka-avro-serializer-3.2.1

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

Я создаю запланированный пунктуатор на трансформаторе и планирую его периодическую работу...

В настоящее время я работаю над загрузочным приложением Spring, используя Spring Kafka Consumer API

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

Я хочу знать, была ли запись в kafka успешной с помощью spring-cloud-stream. public boolean...

У меня есть приложение, в котором я обрабатываю поток и преобразую его в другой.Вот пример: public...

Последняя версия Kafka, доступная для скачивания, - Kafka 2.1.0.Но чтобы использовать Kafka в Spark...

Может кто-нибудь, пожалуйста, помогите мне в этом.У меня проблема с производительностью при...

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

Я вижу в документации, что KSQL поддерживает формат Avro через реестр Confluent Schema.Но что, если...

У меня есть приложение Spark Streaming, которое читает из раздела Kafka. Я управляю смещениями...

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

Ниже показано, как я читаю данные из kafka. val inputDf = spark.readStream

У меня есть потоковый код pyspark, который считывает данные сердцебиения с сервера kafka.Я могу...

Я пытаюсь транслировать данные из темы kafka avro. Ниже приведен мой фрагмент кода: val...

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