Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
MIME-Version: 1.0
In-Reply-To: <1446845718677-5773460.post@n5.nabble.com>
References: <1444397969764-5772464.post@n5.nabble.com>
 <1444662785259-5772580.post@n5.nabble.com>
 <1446845718677-5773460.post@n5.nabble.com>
From: Paolo Antinori <sonicaaaa@gmail.com>
Date: Mon, 9 Nov 2015 09:55:00 +0100
Message-ID: 
 <CAO4YhkhLgnvYWUvOmOe7fcCdSA-kdjonEuEBAbQ2Dr5veuy-bQ@mail.gmail.com>
Subject: Re: Camel zookeeper is not creating the znode
To: users@camel.apache.org
Content-Type: text/plain; charset=UTF-8

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 <drmaas@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.