kafka-consumer-api

0зной

1ответ

Как я могу получить объект схемы Avro из полученного сообщения в kafka?

Я пытаюсь опубликовать/уничтожить объекты java для kafka. Я использую схему Avro. Моя основная программа работает нормально. В моей программе я использую свою схему в производителю (для кодирования) и

apache-kafka avro kafka-consumer-api 2016-04-15

---

7зной

1ответ

Avro расшифровывает java.io.EOFException

Я использую схему Avro Avro с Kafka 0.0.8V. Я использую ту же схему на концах производителя/потребителя. Существует NO ANY Изменения в схеме. Но я получаю какое-то исключение у потребителя, когда пыта

apache-kafka avro kafka-consumer-api 2016-04-18

---

0зной

2ответ

Каковы плюсы и минусы создания брокера kafka и zookeeper в двух докеровских конистерах на одной машине

Я создаю трубопровод данных кафки с тремя брокерами кафки и тремя зоопарками, поэтому мне нужно использовать 6 машин для развертывания 3 брокеров и 3 zookepers , Есть два способа уменьшить нет/машин б

docker apache-kafka apache-zookeeper kafka-consumer-api kafka-producer-api 2016-04-20

---

0зной

1ответ

JBOSS дает org.apache.kafka.common.KafkaException: auth.conf не может быть прочитан

Когда я развертываю войну моего простого проекта kafka (который отлично работает как фляга) в wildfly v 10, я получаю исключение соединения zookeeper [ 1] .Это происходит, когда Кафка слушатель начина

jboss apache-kafka wildfly kafka-consumer-api wildfly-10 2016-04-21

---

6зной

2ответ

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

Мы разрабатываем поточную систему на основе кафки, в которой производитель будет производить несколько разделов в рамках своей темы, и один потребитель будет потреблять из этой темы. Я знаю, что kafka

streaming apache-kafka kafka-consumer-api 2016-04-21

---

0зной

1ответ

Kafka производитель создает тему, но не умеет отправлять сообщения

Я новичок в Scala и Kafka, и у меня возникли проблемы. Я пытаюсь подключить производитель scala kafka к серверу kafka, который установлен на сервере cloudera express. Я сделал это уже один раз в вирту

scala cloudera-cdh kafka-consumer-api kafka-producer-api 2016-04-21

---

2зной

1ответ

Весна Интеграция kafka: org.apache.kafka.common.config.ConfigException во время работы пользователя

Я попытался запустить потребитель Kafka из кода, который он всегда исключает, но я запустил файл kafka-console-consumer.sh, чтобы проверить, работает ли он отлично и показать все сообщения, полученные

spring spring-integration apache-kafka kafka-consumer-api 2016-04-26

---

2зной

2ответ

Список регистрации потребителей kafka в zookeeper

Я использую C++ kafka lib для производства/потребления сообщений с помощью kafka - все отлично работает. Теперь я хочу контролировать моего потребителя, чтобы обрабатывать разъединения/сбой. Я ищу спи

c++ apache-kafka apache-zookeeper kafka-consumer-api 2016-04-27

---

1зной

1ответ

Kafka дает NoSuchElementException

Я создал тему с несколькими разделами через Java-код, который упоминается ниже. private void existOrCreateTopicsWithPartition(Properties prop) { String kafkaServer = prop.getProperty(KafkaProduce

spring-integration apache-kafka kafka-consumer-api kafka-producer-api 2016-04-29

---

0зной

1ответ

Получение тайм-аута чтения ошибки сокета для настройки кластера kafka

Я хочу настроить настройку типа кластера kafka для трех похожих приложений, имеющих одинаковые очереди, такие как AppA -> {TopicX, TopicY, TopicZ}, AppB -> {TopicX, TopicZ} AppC -> {TopicX, TopicY}. П

php timeout apache-kafka kafka-consumer-api 2016-05-02

---