darksungg commented on issue #6832:
URL: https://github.com/apache/pulsar/issues/6832#issuecomment-620391268
Hey @jiazhai thank you for the response.
Please see below the producer (us-east), consumer(us-west) code:
Producer:
this.client = PulsarClient.builder()
.serviceUrl(serviceUrl)
.build();
String topic = "persistent://my-tenant/my-namespace/my-topic";
Producer<byte[]> producer = client.newProducer()
.topic(topic)
.messageRoutingMode(MessageRoutingMode.RoundRobinPartition)
.create();
producer.send(message.getBytes());
Consumer:
this.client = PulsarClient.builder()
.serviceUrl(serviceUrl)
.build();
Pattern allTopicsInNamespace =
Pattern.compile("persistent://my-tenant/my-namespace/my-topic.*");
this.consumer = client.newConsumer()
.topicsPattern(allTopicsInNamespace)
.subscriptionName("my-sub")
.subscriptionType(SubscriptionType.Shared)
.subscribe();
There are 2 clusters, deployed with the terraform-ansbile scripts, i produce
in us-east and consume in us-west. As stated above, the sub is shared. Problem
is that every time i try to sub to a multi-topic, the subscribe() method gets
stuck. If i try on a normal topic, things are good.
Thanks for the help!
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
