kafka-consumer-api

2зной

1ответ

Предотвращение потери сообщения с Кафка высокого уровня потребительских 0.8.x

Типичный Кафка потребитель выглядит следующим образом: Кафка-брокер ---> Кафка-потребитель ----> вниз по течению потребителя как Elastic-Search И в соответствии с документацией для Kafka High Level Co

6зной

2ответ

kafka upgrade to .9 с новым потребителем api

Мы обновляем нашу реализацию kafka до 0,9 и используя новую потребительскую java-апи для создания потребителя. Я использую ниже код для потребителя, и мы используем тему настройки для потребителя, как

0зной

1ответ

Я новичок в kafka. Потребитель, что я создаю не получает сообщение о том, что производитель публикует

Я создаю потребитель (потребительскую группу с одним потребителем в нем): Properties properties = new Properties(); properties.put("zookeeper.connect","localhost:2181"); properties.put("auto

1зной

2ответ

Несколько тем на одном разделе?

Мне было просто интересно и не удалось найти информацию по этому вопросу. Мой вопрос: может ли быть несколько тем на одном разделе? Если да, то как они будут производиться в этом разделе или будут пот

0зной

1ответ

KafkaSpout (Storm) Не отображается в Kafka Manager

Я использую KafkaSpout с конфигурацией ZkHosts, как описано here. Это как SpoutConfig инициализируется: SpoutConfig kafkaConfig = new SpoutConfig(kafkaBrokerHosts, kafkaTopic, "/consumers" , to

0зной

1ответ

Почему Kafka Consumer продолжает получать те же сообщения (смещение)

У меня есть веб-служба SOAP, которая отправляет сообщение с запросом kafka и ждет ответного сообщения kafka (например, consumer.poll (10000)). Каждый раз, когда веб-сервис называется, он создает новог