Apache Kafka против Apache Storm

Apache Kafka: распределенная система обмена сообщениямиApache Storm: обработка сообщений в реальном времениКак мы можем использовать обе технологии в конвейе...

как использовать Kafka 0.8 Log4j appender

Я пытаюсь запустить приложение Kafka-0.8 Log4j и не могу это сделать. Я хочу, чтобы мое приложение отправляло журнал напрямую в kafka через приложение Log4j....

Проблема с балансировкой при чтении сообщений в Кафке

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

Что означает kafka.common.OffsetOutOfRangeException

Я пытаюсь загрузить данные через Apache Kafka и постоянно получаю эту ошибку:kafka.common.OffsetOutOfRangeException: смещение 1003786 выходит за пределы диап...

Как Кафка вещает на многие потребительские группы

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

Каковы лучшие практики для создания мультитенантного приложения в контексте Kafka и шторма?Например: создать тему для каждого арендатора и использовать носит...

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

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

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

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

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

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

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

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