Кафка Storm HDFS / S3 поток данных

Использование Kafka в качестве (CQRS) хранилища событий. Отличная идея?

Хотя я'мы сталкиваемсяКафка раньше, я только недавно понял, что Кафка может быть использована как (основа)CQRS,eventstore.Один из основных моментов, кото...

Есть ли способ удалить все данные из темы или удалить тему перед каждым запуском?

Есть ли способ удалить все данные из темы или удалить тему перед каждым запуском?Могу ли я изменить файл KafkaConfig.scala, чтобы изменить

Кафка: не может создать многопотоковых потребителей

Я только начал работать с Kafka 0.8 beta 1. У меня есть очень простой пример, проблема в том, что я могу заставить работать только одного потребителя сообщен...

Как интегрировать Storm и Kafka [закрыто]

Я работал вГроза и разработал базовую программу, которая использует локальный текстовый файл в качестве источника ввода. Но теперь я должен работать над пото...

Кодек сообщений Kafka - сжать и распаковать

Когда используешьКафкаЯ могу установить кодек, установив свойство kafka.compression.codec моего производителя kafka.Предположим, я использую сжатие snappy в ...

Потребление сообщений Apache Kafka, когда число перегородок превышает количество потребителей

Сколько производителей создать в кафке?

Задержка в потреблении потребителями сообщений в Apache Kafka

Я использую Kafka 0.8.0 и пытаюсь достичь нижеприведенного сценария.JCA API (действует как производитель и отправляет данные) -----> Consumer ------> H...

Kafka High Level Consumer Извлекает все сообщения из темы с помощью Java API (эквивалентно --from-begin)

Я тестирую Kafka High Level Consumer, используя код ConsumerGroupExample с сайта Kafka. Я хотел бы получить все существующие сообщения по теме «test», которы...