crazyman2010 opened a new issue, #1078: URL: https://github.com/apache/rocketmq-clients/issues/1078
### Before Creating the Bug Report - [x] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq-clients/discussions). - [x] I have searched the [GitHub Issues](https://github.com/apache/rocketmq-clients/issues) and [GitHub Discussions](https://github.com/apache/rocketmq-clients/discussions) of this repository and believe that this is not a duplicate. - [x] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ. ### Programming Language of the Client Java ### Runtime Platform Environment ubutntu 24.04 ### RocketMQ Version of the Client/Server client 5.0.8 server 5.3.3 proxy mode: local ### Run or Compiler Version openjdk 21 ### Describe the Bug 在docker中启用了proxy，然后映射了端口17881->8081， 客户端创建失败： 测试代码： ` ClientServiceProvider provider = ClientServiceProvider.loadService(); ClientConfiguration clientConfig = ClientConfiguration.newBuilder() .setEndpoints("192.168.1.32:17881") .enableSsl(false) .build(); Producer producer = provider.newProducerBuilder() .setClientConfiguration(clientConfig) .setTopics("TestTopic") .build(); ` java.lang.IllegalStateException: Stream is already completed, no further calls are allowed java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Stream is already completed, no further calls are allowed at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:592) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:571) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.FluentFuture$TrustedFuture.get(FluentFuture.java:91) at org.apache.rocketmq.client.java.impl.ClientImpl.startUp(ClientImpl.java:188) at org.apache.rocketmq.client.java.impl.producer.ProducerImpl.startUp(ProducerImpl.java:119) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractIdleService$DelegateService.lambda$doStart$0(AbstractIdleService.java:64) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.Callables.lambda$threadRenaming$3(Callables.jav a:105) at java.base/java.lang.Thread.run(Thread.java:1583) 另外发现，如果不使用docker，一切正常 尝试N小时后，发现了问题： <img width="1827" height="534" alt="Image" src="https://github.com/user-attachments/assets/c1c9d144-7e9e-4b21-b831-5e64348526d1"; /> 指定了endponts端口为17881，但是后面却访问了8081，这显然是个bug 临时解决方案：指定proxy端口为17881，保持和外部端口一致。 ### Steps to Reproduce see description ### What Did You Expect to See? 应该访问ClientConfiguration指定的端口 ### What Did You See Instead? see description ### Additional Context _No response_ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
