2018-03-11 15:59:22 UTC - Karthik Palanivelu: Thank you.
----
2018-03-11 16:01:12 UTC - Karthik Palanivelu: Is there any open feature to take 
multiple urls for a endpoint within a producer to switch in case of a failure? 
Or advice me if I perform a retry manually from a producer will work on the 
message order.
----
2018-03-11 18:59:34 UTC - Karthik Palanivelu: One more question is whether the 
bookies will have the messages of all 3 regions if I set the replica to 3 based 
on above example of creating cluster out of standalone broker?
----
2018-03-12 05:49:19 UTC - david-jin: [root@meari-eu-ecs-pulsar 
apache-pulsar-1.21.0-incubating]# bin/pulsar-client consume -s mysub 
<persistent://meari/global/ns/test>
13:48:20,401 ERROR Error while consuming messages
13:48:20,402 ERROR Policies not found for meari/global/ns namespace
org.apache.pulsar.client.api.PulsarClientException$BrokerMetadataException: 
Policies not found for meari/global/ns namespace
        at 
org.apache.pulsar.client.impl.ClientCnx.getPulsarClientException(ClientCnx.java:516)
        at 
org.apache.pulsar.client.impl.ClientCnx.handlePartitionResponse(ClientCnx.java:289)
        at 
org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:100)
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
        at 
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
        at 
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
        at 
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334)
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
        at 
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926)
        at 
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:979)
        at 
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:401)
        at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:306)
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
        at 
io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
        at java.lang.Thread.run(Thread.java:748)
----
2018-03-12 05:49:40 UTC - david-jin: I got these errors
----

Reply via email to