[
https://issues.apache.org/jira/browse/CAMEL-10088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349083#comment-15349083
]
Claus Ibsen commented on CAMEL-10088:
-------------------------------------
Its with bit T in time, eg zookeeperSyncTimeMs
The option is shown here:
https://github.com/apache/camel/blob/camel-2.16.x/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java#L95
> zookeeperSyncTimeMs does not work as Consumer or Producer
> ---------------------------------------------------------
>
> Key: CAMEL-10088
> URL: https://issues.apache.org/jira/browse/CAMEL-10088
> Project: Camel
> Issue Type: Bug
> Components: camel-kafka
> Affects Versions: 2.16.3
> Reporter: SunChaoqun
> Priority: Minor
>
> when I use "zookeeperSyncTimeMs" option , it will raise an error :
> set on the endpoint. Check the uri if the parameters are spelt correctly and
> that they are properties of the endpoint. Unknown
> parameters=[{zookeeperSynctimeMs=111}]
> at
> org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:201)
> at
> org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:944)
> at
> org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:3260)
> at
> org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:2983)
> at
> org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:175)
> at
> org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2814)
> at
> org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2810)
> at
> org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2833)
> at
> org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:2810)
> at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> at
> org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2779)
> at org.apache.camel.main.Main.doStart(Main.java:126)
> at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> at org.apache.camel.main.MainSupport.run(MainSupport.java:124)
> at
> local_project.kafkaconsumer_0_1.KafkaConsumer.run(KafkaConsumer.java:135)
> at
> local_project.kafkaconsumer_0_1.KafkaConsumer.runJobInTOS(KafkaConsumer.java:197)
> at
> local_project.kafkaconsumer_0_1.KafkaConsumer.main(KafkaConsumer.java:167)
> the doc. described this option , but it doesn't work .
> http://camel.apache.org/kafka
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
