Hi Jason, It is a bit confusing, but in the createConsumerPool there is a line:
KafkaProcessorUtils.buildCommonKafkaProperties(context, ConsumerConfig.class, props); That ends up looping through all the properties of the processor and checking if their name matches any of the names in ConsumerConfig, and if so it adds the key/value to the config map. So since the property is named "max.poll.records", that is the same name in ConsumerConfig. Thanks, Bryan On Tue, Jul 7, 2020 at 9:32 AM Jason Iannone <bread...@gmail.com> wrote: > Hi all, > > I have been digging through the ConsumeKafka_2_0 (and record) code and > noticed that the PropertyDescriptor for MAX_POLL_RECORDS isn't connected to > anything. Is this intentional, and a "deprecated field" or am I missing > something? > > Thanks, > Jason >
