[
https://issues.apache.org/jira/browse/CAMEL-20372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aniket Jadhav updated CAMEL-20372:
----------------------------------
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.*
was:
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.
> 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
> Priority: Blocker
>
> 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)
