SunChaoqun created CAMEL-10088:
----------------------------------

             Summary: 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)

Reply via email to