Kafka Consumer - Читать ФИКСИРОВАННОЕ количество сообщений - PullRequest
0 голосов
/ 25 октября 2018

Могу ли я создать потребителя кафки для чтения ФИКСИРОВАННОГО (скажем, 100) количества сообщений в Кафке?Мое состояние в любом случае не должно превышать 100, меньше 100 - хорошо.

1 Ответ

0 голосов
/ 25 октября 2018

Вы можете установить max.poll.records на 100. Оно обозначает максимальное количество записей, возвращаемых за один вызов poll ().

Вы можете найти больше пользовательских конфигов здесь: https://kafka.apache.org/documentation.html#newconsumerconfigs

...