потреблять минимум n записей и максимум n записей, но возвращать записи после ожидания в течение m секунд

Question

У меня есть вариант использования, когда потребитель должен использовать минимум n записей, чтобы начать следующую обработку, но после ожидания в течение m секунд должен вернуть p записей, где p

Answer 1

Отсутствует fetch.min.records потребительская собственность.

Если ваши записи имеют одинаковые размеры, вы можете аппроксимировать свой алгоритм с помощью fetch.min.bytes и fetch.max.wait.ms.

max.poll.records hasn 'Это действительно поможет вам, за исключением случаев, когда n записей уже доступны.