GitHub user huangjun0124 closed a discussion: java pulsar-client get broker returns localhost
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 GitHub link: https://github.com/apache/pulsar/discussions/21881 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
