Изменение количества записей для выборки в Spring Kafka

Question

У меня есть служба весенней загрузки, у которой есть потребитель kafka.Я использую spring-kafka для создания потребителя.

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

Но моя проблема в том, что я хочу изменить значение max.poll.records на основании нескольких других условий.

Как мы можем добиться этого, используя spring-kafka?Любая помощь будет оценена.

Answer 1

Если вы имеете в виду изменить его во время выполнения, это невозможно сделать;свойство отправляется в Kafka при создании потребителя.

Чтобы изменить его, необходимо остановить контейнер, изменить свойство и перезапустить контейнер.Для изменения свойства во время выполнения вам потребуется пользовательская фабрика потребителей, которая имеет подклассы DefaultKafkaConsumerFactory и переопределяет

protected KafkaConsumer<K, V> createKafkaConsumer(Map<String, Object> configs) {

.