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
----
