Apache Kafka - KafkaStream по теме / разделу

Я пишу Kafka Consumer для распределенных приложений с большими объемами и высокой скоростью. У меня только одна тема, но рейтинг входящих сообщений очень выс...

Является ли Zookeeper обязательным для Кафки?

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

Кафка: написание кастомного сериализатора

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

Кафка одиночный потребительский сбой в группе

Я на начальной стадии изучения Kafka, версия 0.8.1.1.Я успешно выполнил Пример группы потребителей, с несколькими разделами и его распределением сообщений ср...

Ошибка примера Apache Kafka: не удалось отправить сообщение после 3 попыток

Когда / как тема, помеченная для удаления, будет окончательно удалена?

Я выдал команду на удаление темы:

Не удалось записать данные смещения в zookeeper в kafka-storm

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

Перезапуск потребителя Kafka (python) снова потребляет все сообщения в очереди

Я использую Kafka 0.8.1 и Kafka python-0.9.0. В моей настройке у меня есть 2 брокера кафки. Когда я запускаю своего потребителя kafka, я вижу, как он извлека...

Как получить список тем с сервера kafka на Java

я использую

Потребитель Kafka Java никогда не получает никаких сообщений