например, с 1000 по 2000 смещение.
2. как получить максимальное количество за раз в java? допустим, max.poll.records=1000 и какой бы тайм-аут не был передан в poll(), возвращается по 150-190 сообщений, не более.
скорее всего еще ограничение ловите по дефолтному ограничению пейлоада который в себя может втянуть консумер если у вас Kafka Stream
не, обычный KafkaConsumer
Возможно там тоже это есть
Посмотрите еще в сторону увеличения max.partition.fetch.bytes. Возможно, потребуется потюнить этот параметр вместе с fetch.max.bytes
настраивать достаточно только консюмер или брокер тоже тюнить надо?
Обсуждают сегодня