Класс KafkaUtils не найден в потоковой передаче Spark

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

Почему потребители Kafka подключаются к зоопарку, а производители получают метаданные от брокеров?

Spark streaming StreamingContext.start () - Ошибка запуска приемника 0

У меня есть проект, использующий потоковую передачу по искру, и я запускаю его с помощью «spark-submit», но у меня возникает эта ошибка:

Потребление от Кафки не удалось Итератор находится в состоянии сбоя

Медленный потребительский throuput при использовании 2 customer-конфигурации

Используя расширение spring -gration-kafka и следующую конфигурацию:

Kafka Producer - по умолчанию поддерживает многопоточность?

Я новичок в Кафке. Я создал примеры программ для производителя и группы потребителей kafka sync, используя kafka_2.9.2-0.8.1.1. Итак, мой вопрос: нужно ли до...

Java, Как получить количество сообщений в теме в apache kafka

Я использую Apache Kafka для обмена сообщениями. Я реализовал производителя и потребителя в Java. Как мы можем получить количество сообщений в теме?

Алгоритм перебалансировки потребителей Kafka

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

обработка логов в реальном времени с использованием Apache Spark Streaming

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

изменение срока хранения кафки во время выполнения

В Kafka 0.8.1.1 как изменить время хранения журнала во время его работы?документация говорит, что собственность