kafka-consumer-api

1зной

1ответ

Почему мои потребители Kafka с одинаковым идентификатором группы не сбалансированы?

Я пишу доказательство концепции приложения, чтобы потреблять сообщения от Apache Kafka 0.9.0.0 и посмотреть, могу ли я использовать его вместо обычного брокера сообщений JMS из-за преимуществ, предост

1зной

1ответ

Инструменты для чтения потребительского смещения от kafka 0.9

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

1зной

1ответ

Исходный код для kafka_2.9.2, версия 0.8.2.1

Как скомпилировать исходный код для следующей зависимости. И где я могу получить исходный код для той же зависимости? Пожалуйста, предоставьте мне ссылку. Я хочу скомпилировать исходный код после доба

5зной

1ответ

Потребитель Kafka выходит за пределы диапазона без настройки политики сброса для разделов

Я получаю исключение, когда начинаю потребитель Kafka. org.apache.kafka.clients.consumer.OffsetOutOfRangeException: Смещения вне диапазона, без сконфигурированного политики сброса для разбиений {тест-

0зной

1ответ

Автоматический масштабируемый рабочий/демон в качестве потребителя Kafka

Мы планируем иметь потребителя Kafka на Java в качестве демона, который должен обнюхать Kafka для сообщений, но хотел бы знать, как мы можем автомасштабировать этого демона (-ов). Пожалуйста, предложи

0зной

1ответ

Кафка 0,90 потребителя упорствовать группу между запусками

я построил следующий Кафка потребитель: Properties props = new Properties(); props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:6667"); props.put(ConsumerConfig.GROUP_ID_CONFIG, "TEST1");

0зной

1ответ

Имеет ли kafka верхний предел количества пользователей, которых он может поддерживать?

Я помню, что существует ограничение на то, сколько потребителей Kafka может поддержать, но не смог найти документацию по этому поводу.

4зной

1ответ

не удалось установить «max.poll.records» под потребителем kafka, где cons.poll все еще возвращает все записи под разделом

Я создал многопоточное потребительское приложение для работы с различными разделами. Изучая различные блоги, я узнал о свойстве «max.poll.records», чтобы получить контроль над набором записей из данно