Проблема в подключении кафки извне

Я использую hortonwork Sandbox для сервера kafka, пытаясь соединить kafka из затмения с помощью кода Java. Используйте эту конфигурацию для подключения к про...

org.apache.spark.SparkException: задача не сериализуема

Это пример рабочего кода:

Кафка: Получить брокерский хост от ZooKeeper

Как изменить начальное смещение для темы?

Spark Python Авро Кафка Десериализатор

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

Zookeeper, имеющий KeeperException, но Кафка умеет создавать темы и производить / потреблять

Недавно я настроил Kafka на CDH 5 с одним узлом, чтобы поиграть с ним на одном узле, прежде чем переходить к реальному кластеру. Сначала я только запустил се...

Не удалось получить метаданные Kafka для пользователей по темам

Кафка нескольких потребителей на раздел

Kafka QuickStart, advertised.host.name дает kafka.common.LeaderNotAvailableException

Я могу получить простой одноузловой Kafka (kafka_2.11-0.8.2.1), работающий локально на одной машине с Linux, но когда я пытаюсь запустить продюсер удаленно, ...

Как мне использовать несколько потребителей в Кафке?

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