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. |
Beta Was this translation helpful? Give feedback.
1 reply
-
Tried again, using the below command:
would still pop error,:
|
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
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
Beta Was this translation helpful? Give feedback.
All reactions