kafka-consumer-api

1зной

1ответ

Как получить размер (метаданные) сообщения без запроса на выбор в Кафке через SimpleConsumer?

Я использую SimpleConsumer и пытаюсь вывести размер сообщения мудрый (байты) с использованием искры. Я могу получить самое раннее и последнее смещение, используя запрос метаданных, но не знаю, как пол

apache-spark apache-kafka kafka-consumer-api 2015-07-16

---

17зной

2ответ

Как использовать потребительский API Kafka 0.8.2?

Я начинаю с самого последнего документа Кафки http://kafka.apache.org/documentation.html. Но я сталкиваюсь с некоторыми проблемами, когда я пытаюсь использовать новый API-интерфейс Consumer. Я сделал

apache-kafka kafka-consumer-api 2015-06-16

---

2зной

1ответ

Kafka Ошибка получения данных смещения. Причина: 1

Я запускаю программу java, которая использует библиотеку kafka и проверяет зафиксированное смещение группы потребителей от zookeeper каждые 1 сек. программа хорошо работает в течение приблизительно 2

java offset runtimeexception kafka-consumer-api apache-kafka 2015-06-19

---

0зной

1ответ

Что такое параметр счетчика тем для Kafka ConsumerConnector

Я новичок в apache kafka и попробую с приведенными примерами. Следующий фрагмент кода используется для инициализации ConsumerConnector, меня смущает параметр count темы; похоже, это приведет к тому, ч

kafka-consumer-api apache-kafka 2015-06-23

---