kafka-consumer-api

1зной

2ответ

Можно ли читать из нескольких разделов с помощью Kafka Simple Consumer?

Можно ли читать из нескольких разделов с помощью Kafka Simple Consumer? Простой Потребитель использует раздел в следующем: PartitionMetadata metadata = findLeader(brokers, port, topic, partition); Si

0зной

2ответ

Возможно ли, чтобы все клиенты в Kafka Consumer Group просматривали одни и те же данные?

Мне нужно прочитать последние сообщения из темы kafka, которая содержит 3 раздела. Мне нужно прочитать те же данные из 5 разных клиентов, сначала я попытался работать с Simple Consumer, но он не работ

10зной

3ответ

Ошибка создания Кафка темы: - коэффициент репликации больше, чем доступные брокеры

Я пытаюсь создать тему Кафки через AdminCommand используя ниже кода Source ZkClient zkClient = new ZkClient(kafkaHost, 10000, 10000, ZKStringSerializer$.MODULE$); AdminUtils.createTopic(zkClient,

1зной

2ответ

Бенчмаркинг Kafka - посредственная производительность

Я сравниваю Kafka 0.8.1.1 потоковым сообщением размера 1k на серверах EC2. Я установил на двух зоопарка m3.xlarge серверов и следующую конфигурацию: dataDir=/var/zookeeper/ clientPor

3зной

3ответ

Завершить работу Kafka Console Consumer, когда все сообщения были прочитаны

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