[CAMEL-20372] kafka Consumer - fix for config maxPollIntervalMs configuration in 3.21.x and 3.22.x

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 3.22.0
• Fix Version/s: 3.21.5, 3.22.2
• Component/s: camel-kafka
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Aniket Jadhav
• Created: 26/Jan/24 13:36
• Updated: 30/Jan/24 05:38
• Resolved: 30/Jan/24 05:38

Description

This is bug from camel side introduce in 3.21.0.

in 3.18.5 camel-kafka passing config values as String.

https://github.com/apache/camel/blob/camel-3.18.5/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java#L596

But after 3.21.0 values pass as is

https://github.com/apache/camel/blob/camel-3.21.0/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java#L590

And in KafkaConfig type of maxPollIntervalMs was Long 

https://github.com/apache/camel/blob/camel-3.18.5/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java#L113

which was wrong against apache-kafka-clients

https://github.com/apache/kafka/blob/3.1.2/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java#L536

Its got fixed in 4.0.0, camel updated type of maxPollIntervalMs to Integer.  

https://github.com/apache/camel/blob/camel-4.0.0/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java#L113

 

We are using 3.22.0 So we require fix in this version also.

Issue Links

• relates to: CAMEL-19570 Kafka max.poll.interval.ms declared in Long and not Integer
• links to: GitHub Pull Request #12949