You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Claus Ibsen (JIRA)" <ji...@apache.org> on 2016/06/25 05:51:16 UTC

[jira] [Commented] (CAMEL-10088) zookeeperSyncTimeMs does not work as Consumer or Producer

    [ 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)