kafka-consumer-api

2зной

2ответ

Кафка обычай потребитель читать входящие записи

я создал Кафки потребителя с помощью нового API (http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html) В настоящее время потребитель читает читает сообще

java apache-kafka kafka-consumer-api 2016-10-16

---

0зной

1ответ

Создание KafkaSpout с идентификатором группы потребителей

С тех пор я много пытаюсь понять, как создать группу kafkaspouts, подписавшись на одну тему. Я нашел, что некоторые источники, ссылающиеся на id в spoutconfig, могут использоваться как идентификатор г

apache-kafka apache-storm kafka-consumer-api kafka-producer-api 2016-10-17

---

0зной

2ответ

Как вычисляется значение смещения kafka?

Значение kafka offeset уникально для раздела или раздела (учитывая тот же идентификатор группы)?

apache-kafka kafka-consumer-api 2016-10-17

---

1зной

1ответ

kafka java клиент не потребляет - просто зависает на consumer.poll

Я следую за книгой Unified Log Processing от Manning, и это первое упражнение - простой потребитель кафки на Java. Программа при запуске просто киосков, где вызывается consumer.poll(). Я бегу это внут

java apache-kafka kafka-consumer-api 2016-10-18

---

1зной

1ответ

Как управлять фиксацией потребляемого сообщения kafka с использованием kafka-node

Я использую узел с kafka в первый раз, используя kafka-node. Потребление сообщения требует вызова внешнего API, что может потребовать от второго ответа. Я хочу преодолеть внезапные неудачи моего потре

node.js apache-kafka kafka-consumer-api 2016-10-18

---

3зной

1ответ

Производитель консоли Kafka потеряет сообщения

Я использую команду производителя консоли kafka ниже, чтобы передать содержимое файла в производител kafka. sh ~/KAFKA_HOME/bin/kafka-console-producer.sh --broker-list xxx:9092,yyy:9092,zzz:9092 --top

hadoop apache-kafka kafka-consumer-api kafka-producer-api bigdata 2016-10-18

---

0зной

1ответ

Что касается чтения и записи в кафке?

Я новичок и пытаюсь повесить на кафку. Я прочитал из документации, что как производитель, так и потребитель запрашивает раздел, будут представлены в реплике лидера. Означает ли это, что потребитель не

apache-kafka kafka-consumer-api 2016-10-18

---

0зной

1ответ

удалить потребительское смещение kafka с новым потребителем api

Можно ли удалить потребительское смещение при использовании нового потребительского API? bin/kafka-consumer-groups.sh выходы: WARNING: Group deletion only works for old ZK-based consumer groups, and o

apache-kafka kafka-consumer-api 2016-10-20

---