You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by drmaas <dr...@gmail.com> on 2015/11/06 22:35:18 UTC
Re: Camel zookeeper is not creating the znode
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.
Re: Camel zookeeper is not creating the znode
Posted by Paolo Antinori <so...@gmail.com>.
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 <dr...@gmail.com> 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.