Hi, I have just tried to use camel-zookeeper component and it worked fine for me.
Regarding Akram example, probably you haven't created the znodes until the location where you want to create yours. ex. /path1/child1 needs to exist, if you want camel-zookeeper being able to create /path1/child1/test.txt On Fri, Nov 6, 2015 at 10:35 PM, drmaas <[email protected]> wrote: > Similar issue with this uri: > > String fullUri = > "zookeeper:${kafkaProperties.zookeeperConnect}${endpoint.lockNode}?create=true&createMode=EPHEMERAL_SEQUENTIAL&repeat=true" > > Logs: > > {"@timestamp":"2015-11-06T15:19:15.026-06:00","@version":1,"message":"Node > '/imn_loader-v1/delta-test-foo/3c15c2ccbe24.com-625f789b-8809-482f-b86f-e062dd0356aa' > did not exist, creating > it.","logger_name":"org.apache.camel.component.zookeeper.ZookeeperProducer","thread_name":"Camel > (camel-1) thread #3 - > timer://products-imn-delta-mainframe-checker","level":"WARN","level_value":30000,"HOSTNAME":"3c15c2ccbe24"} > > > {"@timestamp":"2015-11-06T15:19:15.144-06:00","@version":1,"message":"Error > setting up election node > /imn_loader-v1/delta-test-foo/3c15c2ccbe24.com-625f789b-8809-482f-b86f-e062dd0356aa","logger_name":"org.apache.camel.component.zookeeper.policy.ZooKeeperElection","thread_name":"Camel > (camel-1) thread #3 - > timer://products-imn-delta-mainframe-checker","level":"ERROR","level_value":40000,"stack_trace":"org.apache.zookeeper.KeeperException$NoNodeException: > KeeperErrorCode = NoNode for > /imn_loader-v1/delta-test-foo/3c15c2ccbe24.com-625f789b-8809-482f-b86f-e062dd0356aa\n\tat > org.apache.zookeeper.KeeperException.create(KeeperException.java:111) > ~[zookeeper-3.4.6.jar!/:3.4.6-1569965]\n\tat > org.apache.zookeeper.KeeperException.create(KeeperException.java:51) > ~[zookeeper-3.4.6.jar!/:3.4.6-1569965]\n\tat > org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:783) > ~[zookeeper-3.4.6.jar!/:3.4.6-1569965]\n\tat > org.apache.camel.component.zookeeper.operations.CreateOperation.getResult(CreateOperation.java:52) > ~[camel-zookeeper-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.component.zookeeper.operations.ZooKeeperOperation.get(ZooKeeperOperation.java:70) > ~[camel-zookeeper-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.component.zookeeper.ZookeeperProducer.createNode(ZookeeperProducer.java:223) > ~[camel-zookeeper-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.component.zookeeper.ZookeeperProducer.synchronouslySetData(ZookeeperProducer.java:239) > ~[camel-zookeeper-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.component.zookeeper.ZookeeperProducer.process(ZookeeperProducer.java:90) > ~[camel-zookeeper-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61) > ~[camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190) > [camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:109) > ~[camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:68) > ~[camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:412) > ~[camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:380) > ~[camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:270) > ~[camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.impl.ProducerCache.sendExchange(ProducerCache.java:380) > ~[camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.impl.ProducerCache.send(ProducerCache.java:205) > ~[camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:119) > ~[camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.component.zookeeper.policy.ZooKeeperElection.createCandidateNode(ZooKeeperElection.java:146) > [camel-zookeeper-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.component.zookeeper.policy.ZooKeeperElection.testAndCreateCandidateNode(ZooKeeperElection.java:116) > [camel-zookeeper-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.component.zookeeper.policy.ZooKeeperElection.isMaster(ZooKeeperElection.java:92) > [camel-zookeeper-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.component.zookeeper.policy.ZooKeeperRoutePolicy.onExchangeBegin(ZooKeeperRoutePolicy.java:78) > [camel-zookeeper-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.processor.CamelInternalProcessor$RoutePolicyAdvice.before(CamelInternalProcessor.java:482) > [camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:138) > [camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.component.timer.TimerConsumer.sendTimerExchange(TimerConsumer.java:165) > [camel-core-2.16.0.jar!/:2.16.0]\n\tat > org.apache.camel.component.timer.TimerConsumer$1.run(TimerConsumer.java:73) > [camel-core-2.16.0.jar!/:2.16.0]\n\tat > java.util.TimerThread.mainLoop(Timer.java:555) [na:1.8.0_60]\n\tat > java.util.TimerThread.run(Timer.java:505) > [na:1.8.0_60]\n","HOSTNAME":"3c15c2ccbe24"} > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Camel-zookeeper-is-not-creating-the-znode-tp5772464p5773460.html > Sent from the Camel - Users mailing list archive at Nabble.com.
