I encountered a port error when using pulsar to integrate etcd

[abcMH1966]

When I execute the following command:

./bin/pulsar initialize-cluster-metadata
-c pulsar-cluster
-md etcd:node01:2379,node02:2379,node03:2379
-cms etcd:node01:2379,node02:2379,node03:2379
-uw http://node01:8080,node02:8080,node03:8080
-tw https://node01:8443,node02:8443,node03:8443
-ub pulsar://node01:6650,node02:6650,node03:6650
-tb pulsar+ssl://node01:6651,node02:6651,node03:6651

A port exception occurred：
2022-08-23T10:13:27,784-0400 [grpc-default-executor-0] WARN io.etcd.jetcd.resolver.IPNameResolver - Error wile getting list of servers
java.lang.IllegalArgumentException: port out of range:-1
at java.net.InetSocketAddress.checkPort(InetSocketAddress.java:143) ~[?:1.8.0_322]
at java.net.InetSocketAddress.(InetSocketAddress.java:224) ~[?:1.8.0_322]
at io.etcd.jetcd.resolver.IPNameResolver$HostAndPort.toAddressGroup(IPNameResolver.java:162) ~[io.etcd-jetcd-core-0.5.11.jar:?]
at io.etcd.jetcd.resolver.IPNameResolver.lambda$doResolve$1(IPNameResolver.java:133) ~[io.etcd-jetcd-core-0.5.11.jar:?]
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[?:1.8.0_322]
at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384) ~[?:1.8.0_322]
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) ~[?:1.8.0_322]
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) ~[?:1.8.0_322]
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708) ~[?:1.8.0_322]
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:1.8.0_322]
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566) ~[?:1.8.0_322]
at io.etcd.jetcd.resolver.IPNameResolver.doResolve(IPNameResolver.java:134) ~[io.etcd-jetcd-core-0.5.11.jar:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_322]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_322]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_322]

I set the port to 2379, why the pulsar report this exception:
port out of range: -1
where is the -1 port?

[liangyuanpeng]

What's your pulsar version?

[liangyuanpeng]

I have tests on the docker image of docker pull lypgcs/pulsar:2022-08-23 and it's working for etcd cluster.

You need Change etcd:node01:2379,node02:2379,node03:2379 to etcd:http://node01:2379,http://node02:2379,http://node03:2379

[abcMH1966]

I have tests on the docker image of docker pull lypgcs/pulsar:2022-08-23 and it's working for etcd cluster.

You need Change etcd:node01:2379,node02:2379,node03:2379 to etcd:http://node01:2379,http://node02:2379,http://node03:2379

Thanks for your reply! I'll try it later.

[abcMH1966]

The port exception is resolved. But occur the thread pool exception. It seems that the thread pool configuration is wrong. Do you konw how to resolve it?

[liangyuanpeng]

If you can see some log like Cluster metadata for 'xxx' setup correctly , your cluster metadata is init successed. Then you can ignore this log.

[liangyuanpeng]

If you can see some log like Cluster metadata for 'xxx' setup correctly , your cluster metadata is init successed. Then you can ignore this log.