[GitHub] [pulsar] darksungg commented on issue #6832: Cannot connect to multiple geo-replicated partitioned topics via consumer

darksungg commented on issue #6832: URL: https://github.com/apache/pulsar/issues/6832#issuecomment-620552379 Found the problem, not mentioned in docs : this.client = PulsarClient.builder() .serviceUrl(serviceUrl) .connectionsPerBroker(12)

[GitHub] [pulsar] darksungg commented on issue #6832: Cannot connect to multiple geo-replicated partitioned topics via consumer

darksungg commented on issue #6832: URL: https://github.com/apache/pulsar/issues/6832#issuecomment-620414347 Also would like to ask if the same partition topic needs to be created in both regions or only in one ( we produce only in one region only )

[GitHub] [pulsar] darksungg commented on issue #6832: Cannot connect to multiple geo-replicated partitioned topics via consumer

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

[GitHub] [pulsar] darksungg commented on issue #6832: Cannot connect to multiple geo-replicated partitioned topics via consumer

darksungg commented on issue #6832: URL: https://github.com/apache/pulsar/issues/6832#issuecomment-620144387 Adding to this it seems that testing the issue, having 3 consumers on 1 client for each partition does not work, the second consumer gets stuck at .subscribe().