[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has failed. Run started by GitHub user DongyuanPan (triggered by DongyuanPan). Head commit for run: 16914d8890e82656ca78b60f81e9da122eca85c2 / Dongyuan Pan fix MultiDispatchTest Report URL: https://github.com/apache/rocketmq/actions/runs/6716268578 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user DongyuanPan (triggered by DongyuanPan). Head commit for run: 26fa0501482bbf31c2a64a33f329ab9744ac3800 / fuyou001 [ISSUE #7501] The broker supports idempotence in creating topics (#7502) Report URL: https://github.com/apache/rocketmq/actions/runs/6716292367 With regards, GitHub Actions via GitBox
Re: [I] 开启5个子线程发送5条MQ消息，MqttConsumer 只能收到4条或者更少，必现。 [rocketmq-mqtt]
DongyuanPan commented on issue #215: URL: https://github.com/apache/rocketmq-mqtt/issues/215#issuecomment-1788466427 > 能私信下吗？给个私信方式，咋们交流交流 https://github.com/apache/rocketmq-mqtt/issues/64 这里面有SIG的群，可以扫码进群。 也欢迎私戳我主页邮箱 -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] Are you using RocketMQ MQTT? [rocketmq-mqtt]
DongyuanPan commented on issue #64: URL: https://github.com/apache/rocketmq-mqtt/issues/64#issuecomment-1788465057 If you are interested in this project, you are welcome to join RocketMQ MQTT SIG  -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] 开启5个子线程发送5条MQ消息，MqttConsumer 只能收到4条或者更少，必现。 [rocketmq-mqtt]
DongyuanPan commented on issue #215: URL: https://github.com/apache/rocketmq-mqtt/issues/215#issuecomment-1788461430 > 嗯嗯，好的，7511也是我提的，我们看代码找到了一个暂时的解决方式，将同一个LMQ的消息，始终发送到同一个MessageQuene中，让topic+queneid的锁能生效  嗯嗯，这样可以避免这个问题，目前我提交了一个修改的版本 https://github.com/apache/rocketmq/pull/7525 -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] 开启5个子线程发送5条MQ消息，MqttConsumer 只能收到4条或者更少，必现。 [rocketmq-mqtt]
DongyuanPan commented on issue #215: URL: https://github.com/apache/rocketmq-mqtt/issues/215#issuecomment-1788462099 > > 嗯嗯，好的，7511也是我提的，我们看代码找到了一个暂时的解决方式，将同一个LMQ的消息，始终发送到同一个MessageQuene中，让topic+queneid的锁能生效  > > 嗯嗯，这样可以简单暂时避免这个问题。 目前我提交了一个修改的版本，解决这个并发问题，可以CR一下 [apache/rocketmq#7525](https://github.com/apache/rocketmq/pull/7525) -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq): Workflow run "Coverage" failed!
The GitHub Actions job "Coverage" on rocketmq.git has failed. Run started by GitHub user DongyuanPan (triggered by DongyuanPan). Head commit for run: 16914d8890e82656ca78b60f81e9da122eca85c2 / Dongyuan Pan fix MultiDispatchTest Report URL: https://github.com/apache/rocketmq/actions/runs/6716268576 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #7511]Lock granularity issue causing LMQ message loss [rocketmq]
DongyuanPan commented on PR #7525: URL: https://github.com/apache/rocketmq/pull/7525#issuecomment-1788459477 @guyinyou plz， have a code review -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user DongyuanPan (triggered by DongyuanPan). Head commit for run: dbf32028fafe59c8e4f01e896104d2b2e4c4db29 / Dongyuan Pan fix MultiDispatchTest Report URL: https://github.com/apache/rocketmq/actions/runs/6716260766 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user DongyuanPan (triggered by DongyuanPan). Head commit for run: 16914d8890e82656ca78b60f81e9da122eca85c2 / Dongyuan Pan fix MultiDispatchTest Report URL: https://github.com/apache/rocketmq/actions/runs/6716268584 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has failed. Run started by GitHub user DongyuanPan (triggered by DongyuanPan). Head commit for run: dbf32028fafe59c8e4f01e896104d2b2e4c4db29 / Dongyuan Pan fix MultiDispatchTest Report URL: https://github.com/apache/rocketmq/actions/runs/6716260767 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Coverage" failed!
The GitHub Actions job "Coverage" on rocketmq.git has failed. Run started by GitHub user DongyuanPan (triggered by DongyuanPan). Head commit for run: dbf32028fafe59c8e4f01e896104d2b2e4c4db29 / Dongyuan Pan fix MultiDispatchTest Report URL: https://github.com/apache/rocketmq/actions/runs/6716260765 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #7511]Lock granularity issue causing LMQ message loss [rocketmq]
DongyuanPan commented on PR #7525: URL: https://github.com/apache/rocketmq/pull/7525#issuecomment-1788458203 @pingww plz， have a code review -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq): Workflow run "PR-CI" is working again!
The GitHub Actions job "PR-CI" on rocketmq.git has succeeded. Run started by GitHub user DongyuanPan (triggered by DongyuanPan). Head commit for run: 16914d8890e82656ca78b60f81e9da122eca85c2 / Dongyuan Pan fix MultiDispatchTest Report URL: https://github.com/apache/rocketmq/actions/runs/6716268574 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user DongyuanPan (triggered by DongyuanPan). Head commit for run: 26fa0501482bbf31c2a64a33f329ab9744ac3800 / fuyou001 [ISSUE #7501] The broker supports idempotence in creating topics (#7502) Report URL: https://github.com/apache/rocketmq/actions/runs/6716266505 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "PR-CI" failed!
The GitHub Actions job "PR-CI" on rocketmq.git has failed. Run started by GitHub user DongyuanPan (triggered by DongyuanPan). Head commit for run: dbf32028fafe59c8e4f01e896104d2b2e4c4db29 / Dongyuan Pan fix MultiDispatchTest Report URL: https://github.com/apache/rocketmq/actions/runs/6716260763 With regards, GitHub Actions via GitBox
[PR] Develop fix lmq queue offset [rocketmq]
DongyuanPan opened a new pull request, #7525: URL: https://github.com/apache/rocketmq/pull/7525 ### Which Issue(s) This PR Fixes Fixes #7511 ### Brief Description ### Which Issue(s) This PR Fixes Fixes #7511 ### Brief Description topicQueueLock cannot guarantee that the offset of LMQ is set correctly, so the offset maintenance of LMQ is placed in the critical section protected by putMessageLock. ### How Did You Test This Change? ### How Did You Test This Change? -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq): Workflow run "Coverage" failed!
The GitHub Actions job "Coverage" on rocketmq.git has failed. Run started by GitHub user fujian-zfj (triggered by fujian-zfj). Head commit for run: f6984cc82f607c4e1b263d2c2b1185e0f7438065 / zfj enableTransientPool and sync_flush will cause flush_time_out Report URL: https://github.com/apache/rocketmq/actions/runs/6715758980 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user fujian-zfj (triggered by fujian-zfj). Head commit for run: 26fa0501482bbf31c2a64a33f329ab9744ac3800 / fuyou001 [ISSUE #7501] The broker supports idempotence in creating topics (#7502) Report URL: https://github.com/apache/rocketmq/actions/runs/6715773577 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user fujian-zfj (triggered by fujian-zfj). Head commit for run: f6984cc82f607c4e1b263d2c2b1185e0f7438065 / zfj enableTransientPool and sync_flush will cause flush_time_out Report URL: https://github.com/apache/rocketmq/actions/runs/6715758967 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "PR-CI" is working again!
The GitHub Actions job "PR-CI" on rocketmq.git has succeeded. Run started by GitHub user fujian-zfj (triggered by fujian-zfj). Head commit for run: f6984cc82f607c4e1b263d2c2b1185e0f7438065 / zfj enableTransientPool and sync_flush will cause flush_time_out Report URL: https://github.com/apache/rocketmq/actions/runs/6715758975 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "License checker" is working again!
The GitHub Actions job "License checker" on rocketmq.git has succeeded. Run started by GitHub user fujian-zfj (triggered by fujian-zfj). Head commit for run: f6984cc82f607c4e1b263d2c2b1185e0f7438065 / zfj enableTransientPool and sync_flush will cause flush_time_out Report URL: https://github.com/apache/rocketmq/actions/runs/6715758969 With regards, GitHub Actions via GitBox
[PR] [ISSUE #7523] message will flush timeout when transientStorePoolEnable=true and flushDiskType=SYNC_FLUSH [rocketmq]
fujian-zfj opened a new pull request, #7524: URL: https://github.com/apache/rocketmq/pull/7524 ### Which Issue(s) This PR Fixes Fixes #7523 ### Brief Description 1.set transientStorePoolEnable=true, flushDiskType=SYNC_FLUSH, 2.start broker 3.then send message to broker, client receives FLUSH_DISK_TIMEOUT error By arthas, i find GroupCommitService always return FLUSH_DISK_TIMEOUT -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[I] [Bug] message will flush timeout when transientStorePoolEnable=true and flushDiskType=SYNC_FLUSH [rocketmq]
fujian-zfj opened a new issue, #7523: URL: https://github.com/apache/rocketmq/issues/7523 ### 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/discussions). - [X] I have searched the [GitHub Issues](https://github.com/apache/rocketmq/issues) and [GitHub Discussions](https://github.com/apache/rocketmq/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. ### Runtime platform environment OS, window, linux ### RocketMQ version 5.1.5 ### JDK Version 1.8 ### Describe the Bug  1.set transientStorePoolEnable=true, flushDiskType=SYNC_FLUSH, 2.start broker 3.then send message to broker, client receives FLUSH_DISK_TIMEOUT error By arthas, i find GroupCommitService always return FLUSH_DISK_TIMEOUT  ### Steps to Reproduce 1.transientStorePoolEnable=true flushDiskType=SYNC_FLUSH 2.start broker 3.start to send message 4.client will receive FLUSH_DISK_TIMEOUT ### What Did You Expect to See? no FLUSH_DISK_TIMEOUT received ### What Did You See Instead? FLUSH_DISK_TIMEOUT received ### 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: commits-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] rocketmq-tools should not depend on logback-classic [rocketmq]
travisdowns commented on issue #5347: URL: https://github.com/apache/rocketmq/issues/5347#issuecomment-1788324740 further activity -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [Bug] 无法启动Broker+Proxy [rocketmq]
HappyAxin commented on issue #7520: URL: https://github.com/apache/rocketmq/issues/7520#issuecomment-1788313475 > run `bin/mqadmin clusterList -n 127.0.0.1:9876` to check broker and namesrv started or not proxy启动时报错  -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [Bug] 无法启动Broker+Proxy [rocketmq]
HappyAxin commented on issue #7520: URL: https://github.com/apache/rocketmq/issues/7520#issuecomment-1788289023 > run `bin/mqadmin clusterList -n 127.0.0.1:9876` to check broker and namesrv started or not  好像还是不行 -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] style: polish code to pass checkstyle [rocketmq-e2e]
TheR1sing3un closed pull request #53: style: polish code to pass checkstyle URL: https://github.com/apache/rocketmq-e2e/pull/53 -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq): Workflow run "Snapshot Daily Release Automation" is working again!
The GitHub Actions job "Snapshot Daily Release Automation" on rocketmq.git has succeeded. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 26fa0501482bbf31c2a64a33f329ab9744ac3800 / fuyou001 [ISSUE #7501] The broker supports idempotence in creating topics (#7502) Report URL: https://github.com/apache/rocketmq/actions/runs/6713964680 With regards, GitHub Actions via GitBox
Re: [I] How to judge whether a topic is orderly or unordered? [rocketmq]
PEIYANGXINQU commented on issue #5420: URL: https://github.com/apache/rocketmq/issues/5420#issuecomment-1788200314 收到，谢谢！ -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [ISSUE#5257] Simplify RocketMQ timed task configuration [rocketmq]
github-actions[bot] commented on PR #5362: URL: https://github.com/apache/rocketmq/pull/5362#issuecomment-1788200083 This PR is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs. If you wish not to mark it as stale, please leave a comment in this PR. -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] rocketmq-tools should not depend on logback-classic [rocketmq]
github-actions[bot] commented on issue #5347: URL: https://github.com/apache/rocketmq/issues/5347#issuecomment-1788200111 This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs. -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] Orderly message backlog problem help [rocketmq]
github-actions[bot] commented on issue #5405: URL: https://github.com/apache/rocketmq/issues/5405#issuecomment-1788200066 This issue was closed because it has been inactive for 3 days since being marked as stale. -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] Orderly message backlog problem help [rocketmq]
github-actions[bot] closed issue #5405: Orderly message backlog problem help URL: https://github.com/apache/rocketmq/issues/5405 -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] How to judge whether a topic is orderly or unordered? [rocketmq]
github-actions[bot] commented on issue #5420: URL: https://github.com/apache/rocketmq/issues/5420#issuecomment-1788200035 This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs. -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] Add method to get message queue broker detail info in `DefaultLitePullConsumer` [rocketmq]
github-actions[bot] commented on PR #5429: URL: https://github.com/apache/rocketmq/pull/5429#issuecomment-1788200019 This PR is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs. If you wish not to mark it as stale, please leave a comment in this PR. -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] DefaultMQConsumerWithTraceTest not stable [rocketmq]
github-actions[bot] commented on issue #5433: URL: https://github.com/apache/rocketmq/issues/5433#issuecomment-178812 This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs. -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] Add files via upload [rocketmq]
bibhanshu12 opened a new pull request, #7521: URL: https://github.com/apache/rocketmq/pull/7521 ### Which Issue(s) This PR Fixes Fixes #issue_id ### Brief Description ### How Did You Test This Change? -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[I] [Bug] Please Describe the Bug [rocketmq-clients]
ljjava opened a new issue, #634:
URL: https://github.com/apache/rocketmq-clients/issues/634
### 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
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::from
at
C:\Users\ljjav\.cargo\registry\src\rsproxy.cn-0dccff568467c15b\anyhow-1.0.75\src\error.rs:551
5:
core::convert::impl$3::into
at
/rustc/e5cfc55477eceed1317a02189fdf77a4a98f2124\library\core\src\convert\mod.rs:757
6:
rocketmq::error::ClientError::set_source
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$
>::map_err
>
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$0
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
>
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
>
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
>
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
>
at
C:\Users\ljjav\.cargo\registry\src\rsproxy.cn-0dccff568467c15b\tokio-1.33.0\src\runtime\
Re: [PR] feat: add a flag to retry another broker when not store ok [rocketmq-client-cpp]
ifplusor commented on code in PR #457:
URL:
https://github.com/apache/rocketmq-client-cpp/pull/457#discussion_r1377651905
##
src/producer/DefaultMQProducerImpl.cpp:
##
@@ -410,7 +410,7 @@ SendResult
DefaultMQProducerImpl::sendDefaultImpl(MQMessage& msg,
case ComMode_ONEWAY:
return sendResult;
case ComMode_SYNC:
-if (sendResult.getSendStatus() != SEND_OK) {
+if (sendResult.getSendStatus() != SEND_OK &&
m_retryAnotherBrokerWhenNotStoreOk) {
Review Comment:
Maybe. In Java it is `false`, and I keep it consistent.
https://github.com/apache/rocketmq/blob/26fa0501482bbf31c2a64a33f329ab9744ac3800/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java#L124-L127
--
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: commits-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [I] [Bug] 无法启动Broker+Proxy [rocketmq]
francisoliverlee commented on issue #7520: URL: https://github.com/apache/rocketmq/issues/7520#issuecomment-1787152809 run `bin/mqadmin clusterList -n 127.0.0.1:9876` to check broker and namesrv started or not -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [Bug] 无法启动Broker+Proxy [rocketmq]
francisoliverlee commented on issue #7520: URL: https://github.com/apache/rocketmq/issues/7520#issuecomment-1787149940 > https://rocketmq.apache.org/zh/docs/bestPractice/06FAQ#4-%E9%94%99%E8%AF%AF 的7并不起作用   try bin/mqadmin updateTopic -b 127.0.0.1:10911 . -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [Bug] 无法启动Broker+Proxy [rocketmq]
HappyAxin commented on issue #7520: URL: https://github.com/apache/rocketmq/issues/7520#issuecomment-1786764615 https://rocketmq.apache.org/zh/docs/bestPractice/06FAQ#4-%E9%94%99%E8%AF%AF的7并不起作用   -- 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: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[I] [Bug] 无法启动Broker+Proxy [rocketmq]
HappyAxin opened a new issue, #7520: URL: https://github.com/apache/rocketmq/issues/7520 ### 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/discussions). - [X] I have searched the [GitHub Issues](https://github.com/apache/rocketmq/issues) and [GitHub Discussions](https://github.com/apache/rocketmq/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. ### Runtime platform environment CentOS 7 ### RocketMQ version 5.1.4 ### JDK Version JDK 1.8 ### Describe the Bug 正常按步骤启动  输入测试指令，无法创建消息 ### Steps to Reproduce 见上图 ### What Did You Expect to See? 应该是成功创建1000条消息，而且启动的proxy日志也正常启动 ### What Did You See Instead? ```log org.apache.rocketmq.client.exception.MQClientException: No route info of this topic: TopicTest See https://rocketmq.apache.org/docs/bestPractice/06FAQ for further details. at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:842) at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1526) at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1468) at org.apache.rocketmq.client.producer.DefaultMQProducer.sendDirect(DefaultMQProducer.java:681) at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:393) at org.apache.rocketmq.example.quickstart.Producer.main(Producer.java:78) ```  ### Additional Context 如果我不用broker+proxy启动，只使用broker启动的话，就可以正常的产生消息和消费消息，不知道是我哪里还没有配置好么？或者是个bug？ -- 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: commits-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[I] [Bug] 自定义sendMessageHook的sendMessageAfter被执行多次 [rocketmq]
dousp opened a new issue, #7519: URL: https://github.com/apache/rocketmq/issues/7519 ### 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/discussions). - [X] I have searched the [GitHub Issues](https://github.com/apache/rocketmq/issues) and [GitHub Discussions](https://github.com/apache/rocketmq/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. ### Runtime platform environment win & centos7 ### RocketMQ version - `org.apache.rocketmq:rocketmq-spring-boot-starter:2.2.3` ### JDK Version jdk8 ### Describe the Bug 发送异步数据时发现z自定义hook中的方法被调用多次，打印了多次日志 ### Steps to Reproduce `rocketMQTemplate.asyncSend()` ### What Did You Expect to See? 没有重复调用的日志 ### What Did You See Instead? 出现了重复调用打印的日志 ### Additional Context [讨论](https://github.com/apache/rocketmq/discussions/7518#discussion-5796798) -- 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: commits-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
