Кафка потребительская конфигурация

Question

Как настроить потребителя так, чтобы он опрашивал 50 записей одновременно в одном опросе.Я создал получателя с max_poll_records, установленным на 50. Но мой потребитель потребляет одну запись за раз. Как настроить потребителя так, чтобы он получал 50 записей в одном опросе.

Answer 1

Когда вы устанавливаете max.poll.records, потребитель возвращает самое большее настроенное максимальное количество записей.Скажем, если ваша тема содержит 1000 непрочитанных записей и для max.poll.records установлено значение 50, то потребитель будет возвращать только 50 записей в каждом вызове poll.Но если ваша тема содержит только 5 непрочитанных записей, она немедленно вернет 5 записей.

Если вы хотите обработать записи в пакете, возможно, вам придется накопить записи в списке, а затем обработатьэто когда размер достигает.Примечание. Необходимо отключить автоматическую фиксацию и фиксировать ее вручную после обработки всех 50 записей.