NickYangMin opened a new issue, #1012: URL: https://github.com/apache/rocketmq-clients/issues/1012
### 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 Python ### Runtime Platform Environment exception calling callback for <Future at 0x7f7d77e19550 state=finished raised AioRpcError> Traceback (most recent call last): File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 340, in _invoke_callbacks callback(self) ~~~~~~~~^^^^^^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/client.py", line 350, in __query_topic_route_async_callback raise e File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/client.py", line 347, in __query_topic_route_async_callback res = future.result() File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 449, in result return self.__get_result() ~~~~~~~~~~~~~~~~~^^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 401, in __get_result raise self._exception File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/connection/rpc_client.py", line 212, in __query_route_async_0 return await self.retrieve_or_create_channel(endpoints).async_stub.QueryRoute( ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ req, metadata=metadata, timeout=timeout ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ) ^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/grpc/aio/_call.py", line 327, in __await__ raise _create_rpc_error( ...<2 lines>... ) grpc.aio._call.AioRpcError: <AioRpcError of RPC that terminated with: status = StatusCode.DEADLINE_EXCEEDED details = "Deadline Exceeded" debug_error_string = "UNKNOWN:Error received from peer {grpc_status:4, grpc_message:"Deadline Exceeded"}" > exception calling callback for <Future at 0x7f7d78113d90 state=finished raised AioRpcError> Traceback (most recent call last): File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 340, in _invoke_callbacks callback(self) ~~~~~~~~^^^^^^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/client.py", line 350, in __query_topic_route_async_callback raise e File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/client.py", line 347, in __query_topic_route_async_callback res = future.result() File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 449, in result return self.__get_result() ~~~~~~~~~~~~~~~~~^^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 401, in __get_result raise self._exception File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/connection/rpc_client.py", line 212, in __query_route_async_0 return await self.retrieve_or_create_channel(endpoints).async_stub.QueryRoute( ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ req, metadata=metadata, timeout=timeout ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ) ^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/grpc/aio/_call.py", line 327, in __await__ raise _create_rpc_error( ...<2 lines>... ) grpc.aio._call.AioRpcError: <AioRpcError of RPC that terminated with: status = StatusCode.DEADLINE_EXCEEDED details = "Deadline Exceeded" debug_error_string = "UNKNOWN:Error received from peer {grpc_status:4, grpc_message:"Deadline Exceeded"}" > normal producer example raise exception: failed to fetch topic:acme_assist_rsp_topic route. ### RocketMQ Version of the Client/Server rocketmq-python-client 5.0.6 ### Run or Compiler Version Ubuntu 20.04 ### Describe the Bug exception calling callback for <Future at 0x7f7d77e19550 state=finished raised AioRpcError> Traceback (most recent call last): File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 340, in _invoke_callbacks callback(self) ~~~~~~~~^^^^^^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/client.py", line 350, in __query_topic_route_async_callback raise e File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/client.py", line 347, in __query_topic_route_async_callback res = future.result() File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 449, in result return self.__get_result() ~~~~~~~~~~~~~~~~~^^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 401, in __get_result raise self._exception File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/connection/rpc_client.py", line 212, in __query_route_async_0 return await self.retrieve_or_create_channel(endpoints).async_stub.QueryRoute( ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ req, metadata=metadata, timeout=timeout ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ) ^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/grpc/aio/_call.py", line 327, in __await__ raise _create_rpc_error( ...<2 lines>... ) grpc.aio._call.AioRpcError: <AioRpcError of RPC that terminated with: status = StatusCode.DEADLINE_EXCEEDED details = "Deadline Exceeded" debug_error_string = "UNKNOWN:Error received from peer {grpc_status:4, grpc_message:"Deadline Exceeded"}" > exception calling callback for <Future at 0x7f7d78113d90 state=finished raised AioRpcError> Traceback (most recent call last): File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 340, in _invoke_callbacks callback(self) ~~~~~~~~^^^^^^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/client.py", line 350, in __query_topic_route_async_callback raise e File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/client.py", line 347, in __query_topic_route_async_callback res = future.result() File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 449, in result return self.__get_result() ~~~~~~~~~~~~~~~~~^^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/concurrent/futures/_base.py", line 401, in __get_result raise self._exception File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/rocketmq_python_client-5.0.6-py3.13.egg/rocketmq/v5/client/connection/rpc_client.py", line 212, in __query_route_async_0 return await self.retrieve_or_create_channel(endpoints).async_stub.QueryRoute( ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ req, metadata=metadata, timeout=timeout ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ) ^ File "/home/yangmin/anaconda3/envs/agent/lib/python3.13/site-packages/grpc/aio/_call.py", line 327, in __await__ raise _create_rpc_error( ...<2 lines>... ) grpc.aio._call.AioRpcError: <AioRpcError of RPC that terminated with: status = StatusCode.DEADLINE_EXCEEDED details = "Deadline Exceeded" debug_error_string = "UNKNOWN:Error received from peer {grpc_status:4, grpc_message:"Deadline Exceeded"}" > normal producer example raise exception: failed to fetch topic:acme_assist_rsp_topic route. ### Steps to Reproduce none ### What Did You Expect to See? none ### What Did You See Instead? none ### Additional Context 帮忙看看这个是什么问题，java客户端是可以的 -- 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]
