Я наблюдаю, что экземпляр потребителя не обнаружил ошибку во время регистрации потребителя, даже...

Я пытаюсь прочитать данные из Kafka (1 тема, 5 разделов), используя подход Spark Streaming Direct....

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

Я пытаюсь использовать Kafka 0.10.2 в моем проекте Spark Streaming (который использует библиотеку 1

быстрый вопрос о сохранности данных; обычно на странице dockerhub вы привязываете том, чтобы...

Я использую Python 3.5 и Spark 2.2 Streaming с Kafka, и скрипт не удалось запустить из-за...

У меня есть файл составления докера: influx: image: influxdb:latest container_name: influxdb ports:...

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

Я пытался ./spark-2.3.1-bin-hadoop2.7/bin/spark-submit --packages org.apache

Я реализовал потребителя Kafka с KafkaHandler.Предполагается, что мой потребитель использует...

Источник событий - это поворот на 180 градусов в том, как многие из нас занимаются архитектурой и...

Поскольку я работаю со значениями Json, я не установил значения по умолчанию. Я обрабатываю KStream...

Я использую многофункциональную платформу Confluent https://docs.confluent

В настоящее время я использую Maven с io.fabric8 docker-maven-plugin, чтобы автоматически...

Я пытаюсь подключиться к Kafka с помощью потоковой структурированной искры. Это работает:...

В приложении Spring Boot я пытаюсь настроить Kafka Streams.С простыми темами Kafka все работает...

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

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

Я получаю данные от кафки в виде {"email":"test@example"...

Кафка версия - 1.0.1 Я получаю следующее исключение через случайные интервалы. Попытка увеличить...

Когда я пытаюсь использовать сообщение из темы kafka, используя spark streaming, получаю ошибку...

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

Я пытаюсь запустить код STA / LTA, предназначенный для обнаружения событий при потоковой передаче с...

зная, что мой kafka_cluster работает нормально, и я использую docker-compose Я положил внутрь...

Посмотрите на мой последний комментарий принятого ответа для решения Я настроил DStream так: val...