[jira] [Created] (CAMEL-20372) kafka Consumer - fix for config maxPollIntervalMs

[Aniket Jadhav (Jira)]

Aniket Jadhav created CAMEL-20372:
-------------------------------------

             Summary: kafka Consumer - fix for config maxPollIntervalMs
                 Key: CAMEL-20372
                 URL: https://issues.apache.org/jira/browse/CAMEL-20372
             Project: Camel
          Issue Type: Bug
          Components: camel-kafka
    Affects Versions: 3.22.0
            Reporter: Aniket Jadhav


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.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)