Я кодирую искровое потоковое задание о базе "RecoverableStatefulNetworkWordCount" на...

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

Если в теме kakfa имеется более одного раздела, в java эти экземпляры / потоки потребителя будут...

У меня есть сценарий в моем проекте, где я читаю сообщения темы kafka, используя версию spark-sql-2

У нас есть приложение Streaming Stream.Архитектура выглядит следующим образом: Kinesis Spark to...

Определение в документах: org.apache.spark.streaming.kafka Класс KafkaUtils static...

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

Я пишу потоковое задание, которое считывает данные из Kafka, вносит некоторые изменения в записи и...

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

Я новичок в искровом структурированном потоке и офсетном управлении кафкой.Использование...

Мне нужно решить проблему.У меня есть производитель kafka, который производит сообщения (xmls) на...

Я делаю некоторую статистику, используя потоковое искрение и кассандру.При чтении таблиц cassandra...

Вот кадр данных - в основном, есть два возможных типа - X и Y для разных источников A, B, C, D ......

Всякий раз, когда приложение Stream Streaming пытается передать смещение Кафке, оно становится...

Я пытаюсь запустить проект, который получает твиты с помощью Apache Kafka, обрабатывает их с...

У нас есть две InputDStream из двух тем Кафки, но мы должны объединить данные этих двух входов...

Я читаю данные, поступающие с Kafka (100 000 строк в секунду), используя структурированную...

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

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

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

Я пытаюсь отправить данные из программы в защищенный кластер Kafka (EventStreams в IBM Cloud -...

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

У меня есть данные в двух темах kafka из mysql с использованием debezium-connector-mysql-plugin

Я интегрирую кафку и искру с упругим поиском. когда я запускаю этот скрипт, используя: sudo...

Я создаю одно приложение, в котором я получу потоковые данные (csv) из kafka и запишу их в hdfs....