kafka-consumer-api

1зной

1ответ

Потребитель Kafka не получает сообщения при запуске примера на kafka.apache.org

Я совершенно новичок в Kafka и пытаюсь запустить примеры потребителей на https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example, но он не получает сообщений. Вот выход в консоли Ecli

java apache-kafka kafka-consumer-api 2015-03-11

---

4зной

1ответ

Отправить байт массив штурмовать kafka болт

Я написал штормовую топологию. Я в основном хочу отправить кортежи в схему avro в виде байтового массива в тему кафки. Это, как я поставил болт: builder.setBolt(KAFKA_AVRO_BOLT_NAME, new KafkaBolt<Str

java apache-kafka apache-storm kafka-consumer-api 2015-03-12

---

2зной

1ответ

Имеет ли весна целочисленность kafka поддерживает динамическое создание темы

Я новичок в весенней целой кафке, и я понимаю, что адаптер kafka-oubound-channel. Но есть ли способ, который я могу создавать темы, без необходимости настраивать в контексте xml? ie: на основе моего с

spring spring-integration apache-kafka kafka-consumer-api 2015-03-12

---

2зной

1ответ

Kafka простой потребитель и размер сообщения - читает ли он частичную messsage?

Я использую простой потребитель для чтения из темы kafka и задаю вопрос о том, как размер выборки связан с размером сообщений в теме. Скажем, каждое мое сообщение в теме - 10 kb. Когда я потребляю нач

java apache-kafka kafka-consumer-api 2015-03-13

---

6зной

1ответ

Невозможно связаться с сервером kafka с использованием kafka API-интерфейса производителя

Я установил kafka на одном узле и запустил zookeeper, а также kafka server.I проверил его для внутреннего производителя и потребителя на консоли, и он работает хорошо. Но когда я Я запускаю внутреннег

java apache-kafka kafka-consumer-api 2015-03-17

---

1зной

1ответ

Kafka потребитель высокого уровня

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

java apache-kafka kafka-consumer-api 2015-03-17

---

1зной

2ответ

Магический байт в Apache Kafka

Кто-нибудь знает о магическом байте в Кафке? Для чего он используется и как он используется? Может ли производитель отправить любую ценность в магическом байте на раздел Kafka? Просьба поделиться любо

hadoop analytics bigdata apache-kafka kafka-consumer-api 2015-03-18

---

20зной

2ответ

Удалить сообщение после его использования в KAFKA

Я использую apache kafka для производства и использования файла размером 5 ГБ. Я хочу знать, есть ли способ, когда сообщение из темы автоматически удаляется после его потребления. Имею ли я способ отс

apache-kafka kafka-consumer-api 2015-02-18

---