java pulsar-client get broker returns localhost #21881
Replies: 2 comments 1 reply
|
If I understand your issue correctly, this should have to do with the "advertised listeners" for a pulsar broker: This defines the url that a broker provides during a lookup request. |
1 reply
|
Tried again, using the below command: would still pop error,: |
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Hi, i have a pulsar server, now i connect to it as consumer in java pulsar-client-2.11.1
the service-url is configured as : pulsar://192.168.1.122:6650 which is where the pulsar standalone server running
and when the consumer is created, error occured that it can not connect to 'localhost'
Through debug, i found BinaryProtoLookupService::findBroker function, the lookup request has response :
BinaryProtoLookupService.LookupDataResult(brokerUrl=pulsar://localhost:6650, partitions=-1,authoritative=true,proxyThroughServiceUrl=false,redirect=false)
This would cause the outter function use localhost as the remote pulsar broker server, result in errors
Do anyone know how to solve this error, thanks
All reactions