Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Rust] failed to parse config at client.handle_telemetry_command sending messages #634

Closed
3 tasks done
ljjava opened this issue Oct 31, 2023 · 2 comments · Fixed by #682
Closed
3 tasks done

[Rust] failed to parse config at client.handle_telemetry_command sending messages #634

ljjava opened this issue Oct 31, 2023 · 2 comments · Fixed by #682
Labels
no stale This will never be considered stale type/bug Something isn't working

Comments

@ljjava
Copy link

ljjava commented Oct 31, 2023

Before Creating the Bug Report

  • I found a bug, not just asking a question, which should be created in GitHub Discussions.

  • I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.

  • I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.

Programming Language of the Client

Rust

Runtime Platform Environment

win10 64

RocketMQ Version of the Client/Server

rocketmq5.1.4

Run or Compiler Version

rustc 1.75.0-nightly (e5cfc5547 2023-10-28)

[package]
name = "custrocketmq"
version = "0.1.0"
edition = "2021"

See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

[dependencies]
rocketmq = "5.0.0"
tokio = { version = "1", features = ["full"] }

Describe the Bug

1:broker 已经启动了proxy
sh mqbroker -c /home/rocketmq/rocketmq-5.1.4/conf/broker.conf -pc /home/rocketmq/rocketmq-5.1.4/conf/rmq-proxy.json --enable-proxy

2:并使用官方例子examples/simple_producer.rs发送信息出现错误提示
ERRO[C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\client.rs:196:33] handle telemetry command failed: Failed to parse config at client.handle_telemetry_command => receive telemetry command but there is no handler

详细错误提示:
thread 'main' panicked at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\client.rs:560:62:
called Result::unwrap() on an Err value: Failed to create session at session.create_session => failed to connect to peer

Context:
peer: 172.24.0.4:8081

Source: transport error

Caused by:
0: error trying to connect: deadline has elapsed
1: deadline has elapsed

Stack backtrace:
0: std::backtrace_rs::backtrace::dbghelp::trace
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\std\src....\backtrace\src\backtrace\dbghelp.rs:98
1: std::backtrace_rs::backtrace::trace_unsynchronized
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\std\src....\backtrace\src\backtrace\mod.rs:66
2: std::backtrace::Backtrace::create
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\std\src\backtrace.rs:331
3: std::backtrace::Backtrace::capture
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\std\src\backtrace.rs:297
4: anyhow::error::impl$1::fromtonic::transport::error::Error
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\anyhow-1.0.75\src\error.rs:551
5: core::convert::impl$3::intotonic::transport::error::Error,anyhow::Error
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124\library\core\src\convert\mod.rs:757
6: rocketmq::error::ClientError::set_sourcetonic::transport::error::Error
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\error.rs:122
7: rocketmq::session::impl$1::new::async_fn$0::closure$0
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\session.rs:160
8: enum2$<core::result::Resulttonic::transport::channel::Channel,tonic::transport::error::Error >::map_err<tonic::transport::channel::Channel,tonic::transport::error::Error,rocketmq::error::ClientError,rocketmq::session::impl$1::new::async_fn$0::closure_en
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124\library\core\src\result.rs:829
9: rocketmq::session::impl$1::new::async_fn$0
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\session.rs:159
10: rocketmq::session::impl$19::get_or_create_session::async_fn$0
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\session.rs:567
11: rocketmq::client::impl$3::get_session_with_endpoints::async_fn$0
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\client.rs:342
12: rocketmq::client::impl$3::receive_message::async_fn$0
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\client.rs:560
13: rocketmq::simple_consumer::impl$0::receive_with::async_fn$0<ref$<str$> >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\simple_consumer.rs:157
14: rocketmq::simple_consumer::impl$0::receive::async_fn$0alloc::string::String
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\simple_consumer.rs:123
15: custrocketmq::main::async_block$0
at .\src\main.rs:68
16: tokio::runtime::park::impl$4::block_on::closure$0<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\park.rs:282
17: tokio::runtime::coop::with_budget
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\coop.rs:107
18: tokio::runtime::coop::budget
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\coop.rs:73
19: tokio::runtime::park::CachedParkThread::block_on<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\park.rs:282
20: tokio::runtime::context::blocking::BlockingRegionGuard::block_on<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\context\blocking.rs:66
21: tokio::runtime::scheduler::multi_thread::impl$0::block_on::closure$0<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\scheduler\multi_thread\mod.rs:87
22: tokio::runtime::context::runtime::enter_runtime<tokio::runtime::scheduler::multi_thread::impl$0::block_on::closure_env$0<enum2$custrocketmq::main::async_block_env$0 >,tuple$<> >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\context\runtime.rs:65
23: tokio::runtime::scheduler::multi_thread::MultiThread::block_on<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\scheduler\multi_thread\mod.rs:86
24: tokio::runtime::runtime::Runtime::block_on<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\runtime.rs:350
25: custrocketmq::main
at .\src\main.rs:76
26: core::ops::function::FnOnce::call_once<void ()(),tuple$<> >
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124\library\core\src\ops\function.rs:250
27: std::sys_common::backtrace::__rust_begin_short_backtrace<void (
)(),tuple$<> >
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124\library\std\src\sys_common\backtrace.rs:154
28: std::sys_common::backtrace::__rust_begin_short_backtrace<void (*)(),tuple$<> >
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124\library\std\src\sys_common\backtrace.rs:154
29: std::rt::lang_start::closure$0<tuple$<> >
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124\library\std\src\rt.rs:167
30: std::rt::lang_start_internal::closure$2
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\std\src\rt.rs:148
31: std::panicking::try::do_call
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\std\src\panicking.rs:504
32: std::panicking::try
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\std\src\panicking.rs:468
33: std::panic::catch_unwind
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\std\src\panic.rs:142
34: std::rt::lang_start_internal
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\std\src\rt.rs:148
35: std::rt::lang_start<tuple$<> >
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124\library\std\src\rt.rs:166
36: main
37: invoke_main
at D:\a_work\1\s\src\vctools\crt\vcstartup\src\startup\exe_common.inl:78
38: __scrt_common_main_seh
at D:\a_work\1\s\src\vctools\crt\vcstartup\src\startup\exe_common.inl:288
39: BaseThreadInitThunk
40: RtlUserThreadStart

stack backtrace:
0: std::panicking::begin_panic_handler
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\std\src\panicking.rs:597
1: core::panicking::panic_fmt
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\core\src\panicking.rs:72
2: core::result::unwrap_failed
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124/library\core\src\result.rs:1653
3: enum2$<core::result::Resultrocketmq::session::Session,rocketmq::error::ClientError >::unwraprocketmq::session::Session,rocketmq::error::ClientError
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124\library\core\src\result.rs:1077
4: rocketmq::client::impl$3::receive_message::async_fn$0
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\client.rs:560
5: rocketmq::simple_consumer::impl$0::receive_with::async_fn$0<ref$<str$> >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\simple_consumer.rs:157
6: rocketmq::simple_consumer::impl$0::receive::async_fn$0alloc::string::String
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\simple_consumer.rs:123
7: custrocketmq::main::async_block$0
at .\src\main.rs:68
8: tokio::runtime::park::impl$4::block_on::closure$0<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\park.rs:282
9: tokio::runtime::coop::with_budget
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\coop.rs:107
10: tokio::runtime::coop::budget
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\coop.rs:73
11: tokio::runtime::park::CachedParkThread::block_on<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\park.rs:282
12: tokio::runtime::context::blocking::BlockingRegionGuard::block_on<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\context\blocking.rs:66
13: tokio::runtime::scheduler::multi_thread::impl$0::block_on::closure$0<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\scheduler\multi_thread\mod.rs:87
14: tokio::runtime::context::runtime::enter_runtime<tokio::runtime::scheduler::multi_thread::impl$0::block_on::closure_env$0<enum2$custrocketmq::main::async_block_env$0 >,tuple$<> >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\context\runtime.rs:65
15: tokio::runtime::scheduler::multi_thread::MultiThread::block_on<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\scheduler\multi_thread\mod.rs:86
16: tokio::runtime::runtime::Runtime::block_on<enum2$custrocketmq::main::async_block_env$0 >
at C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\runtime.rs:350
17: custrocketmq::main
at .\src\main.rs:76
18: core::ops::function::FnOnce::call_once<void (*)(),tuple$<> >
at /rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124\library\core\src\ops\function.rs:250
note: Some details are omitted, run with RUST_BACKTRACE=full for a verbose backtrace.
Oct 31 14:59:52.848 DEBG[C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\client.rs:201:25] receive shutdown signal, stop heartbeat task and telemetry command handler, component: client
Oct 31 14:59:52.856 INFO[C:\Users\ljjav.cargo\registry\src\rsproxy.cn-0dccff568467c15b\rocketmq-5.0.0\src\client.rs:206:13] heartbeat task and telemetry command handler are stopped, component: client
error: process didn't exit successfully: target\debug\custrocketmq.exe (exit code: 101)

  • The terminal process "C:\Users\ljjav.cargo\bin\cargo.exe 'run', '--package', 'custrocketmq', '--bin', 'custrocketmq'" terminated with exit code: 101.
  • Terminal will be reused by tasks, press any key to close it.

Steps to Reproduce

每次执行均出现此问题

What Did You Expect to See?

如何解决此问题正常发送信息

What Did You See Instead?

一直有问题

Additional Context

No response

@ljjava ljjava added the type/bug Something isn't working label Oct 31, 2023
@francisoliverlee francisoliverlee changed the title [Bug] Please Describe the Bug [Rust] failed to parse config at client.handle_telemetry_command sending messages Nov 6, 2023
Copy link

github-actions bot commented Dec 7, 2023

This issue is stale because it has been open for 30 days with no activity. It will be closed in 3 days if no further activity occurs.

@github-actions github-actions bot added the stale Pull request is stale label Dec 7, 2023
Copy link

This issue was closed because it has been inactive for 3 days since being marked as stale.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
no stale This will never be considered stale type/bug Something isn't working
Projects
None yet
2 participants