kafka-consumer-api

1зной

1ответ

Я писал потребитель Кафки, и у меня есть запрос, связанный с потребительскими процессами. У меня есть потребитель с groupId="testGroupId" и используя ту же группу. Я использую из нескольких тем, скаже

16зной

4ответ

Как написать файл Kafka Producer

Я пытаюсь загрузить простой текстовый файл вместо стандартного ввода в Kafka. После загрузки Кафку, я выполнил следующие действия: работы зоопарка: bin/zookeeper-server-start.sh config/zookeeper.prope

0зной

3ответ

Kafka распространяет сообщения из раздела среди потребителей

У меня есть тема Kafka, которая в настоящее время имеет 3 раздела. Я хочу, чтобы мои потребители читали один и тот же раздел, но каждое сообщение должно обращаться к другому потребителю круговым спосо

1зной

1ответ

Потребление нескольких тем Кафки у потребителя ржавчины

Я пытаюсь использовать пользователя Rust для чтения из нескольких тем. Это код, у меня сейчас: extern crate kafka; use kafka::client::KafkaClient; use kafka::consumer::Consumer; use kafka::utils;

1зной

1ответ

kafka потребительский опрос увеличивает время выполнения метода

в нашем приложении, потребитель непрерывно начал опрос при загрузке приложения, и поэтому иногда он влияет на время выполнения для одного из методов путем опроса между выполнением метода. Метод (скаже

3зной

4ответ

Kafka: Как подключить kafka-console-consumer, чтобы получить удаленный контент темы брокера?

У меня есть kookka zookeeper и 3 брокера на одной машине на ec2 с портами 9092..9094 и я пытаюсь поглотить содержание темы с другой машины. Порты 2181 (zk), 9092, 9093 и 9094 (серверы) открыты для пот