[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" is working again!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
succeeded.
Run started by GitHub user 3424672656 (triggered by 3424672656).

Head commit for run:
c3b350fb07f56da910343c7a1252c5835ea3e91e / hqbfz 
<125714719+3424672...@users.noreply.github.com>
Merge branch 'apache:develop' into consumer_by_who

Report URL: https://github.com/apache/rocketmq/actions/runs/12172486070

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user AuroraTwinkle (triggered by github-actions[bot]).

Head commit for run:
bc66462f4bba2a13ad5510ec5a727ec6936f5c45 / duanlinlin 

add unit test

Report URL: https://github.com/apache/rocketmq/actions/runs/12062550787

With regards,
GitHub Actions via GitBox



Re: [I] [Bug] dledger集群消息丢失 [rocketmq]

2024-12-04 Thread via GitHub


github-actions[bot] closed issue #7477: [Bug] dledger集群消息丢失
URL: https://github.com/apache/rocketmq/issues/7477


-- 
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] dledger集群消息丢失 [rocketmq]

2024-12-04 Thread via GitHub


github-actions[bot] commented on issue #7477:
URL: https://github.com/apache/rocketmq/issues/7477#issuecomment-2518812570

   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] [Bug] Condition returned by method "testStateAndRecover" in class org.apache.rocketmq.store.timer.TimerMessageStoreTest was not fulfilled within 5 seconds. [rocketmq]

2024-12-04 Thread via GitHub


github-actions[bot] commented on issue #7617:
URL: https://github.com/apache/rocketmq/issues/7617#issuecomment-2518812518

   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



[GH] (rocketmq): Workflow run "Coverage" is working again!

2024-12-04 Thread GitBox


The GitHub Actions job "Coverage" on rocketmq.git has succeeded.
Run started by GitHub user 3424672656 (triggered by 3424672656).

Head commit for run:
c3b350fb07f56da910343c7a1252c5835ea3e91e / hqbfz 
<125714719+3424672...@users.noreply.github.com>
Merge branch 'apache:develop' into consumer_by_who

Report URL: https://github.com/apache/rocketmq/actions/runs/12172486075

With regards,
GitHub Actions via GitBox



Re: [PR] [ISSUE #8995] Fix pull consumers can't be found when querying consumers [rocketmq]

2024-12-04 Thread via GitHub


codecov-commenter commented on PR #8996:
URL: https://github.com/apache/rocketmq/pull/8996#issuecomment-2519019264

   ## 
[Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/8996?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
 Report
   Attention: Patch coverage is `11.1%` with `8 lines` in your changes 
missing coverage. Please review.
   > Project coverage is 47.70%. Comparing base 
[(`f4c4984`)](https://app.codecov.io/gh/apache/rocketmq/commit/f4c498433d19e83510d4181ea9a63fbc7e3115eb?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
 to head 
[(`c3b350f`)](https://app.codecov.io/gh/apache/rocketmq/commit/c3b350fb07f56da910343c7a1252c5835ea3e91e?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache).
   
   | [Files with missing 
lines](https://app.codecov.io/gh/apache/rocketmq/pull/8996?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
 | Patch % | Lines |
   |---|---|---|
   | 
[...apache/rocketmq/broker/client/ConsumerManager.java](https://app.codecov.io/gh/apache/rocketmq/pull/8996?src=pr&el=tree&filepath=broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Fbroker%2Fclient%2FConsumerManager.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-YnJva2VyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9icm9rZXIvY2xpZW50L0NvbnN1bWVyTWFuYWdlci5qYXZh)
 | 11.11% | [7 Missing and 1 partial :warning: 
](https://app.codecov.io/gh/apache/rocketmq/pull/8996?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
 |
   
   Additional details and impacted files
   
   
   ```diff
   @@  Coverage Diff  @@
   ## develop#8996  +/-   ##
   =
   - Coverage  47.77%   47.70%   -0.08% 
   + Complexity 1182011800  -20 
   =
 Files   1305 1305  
 Lines  9138591394   +9 
 Branches   1173611739   +3 
   =
   - Hits   4366143597  -64 
   - Misses 4233342402  +69 
   - Partials5391 5395   +4 
   ```
   
   
   
   [:umbrella: View full report in Codecov by 
Sentry](https://app.codecov.io/gh/apache/rocketmq/pull/8996?dropdown=coverage&src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache).
   
   :loudspeaker: Have feedback on the report? [Share it 
here](https://about.codecov.io/codecov-pr-comment-feedback/?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache).
   


-- 
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!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
failed.
Run started by GitHub user AuroraTwinkle (triggered by Jason918).

Head commit for run:
bc66462f4bba2a13ad5510ec5a727ec6936f5c45 / duanlinlin 

add unit test

Report URL: https://github.com/apache/rocketmq/actions/runs/12062550792

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
failed.
Run started by GitHub user AuroraTwinkle (triggered by github-actions[bot]).

Head commit for run:
bc66462f4bba2a13ad5510ec5a727ec6936f5c45 / duanlinlin 

add unit test

Report URL: https://github.com/apache/rocketmq/actions/runs/12062550792

With regards,
GitHub Actions via GitBox



[I] [Bug] 4.9.3版本 出现sendKernelImpl call timeout 这个报错 [rocketmq]

2024-12-04 Thread via GitHub


jinzhiyuan521ping opened a new issue, #9024:
URL: https://github.com/apache/rocketmq/issues/9024

   ### 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.5
   
   ### RocketMQ version
   
   4.9.3
   
   ### JDK Version
   
   Oracle Jdk 1.8
   
   ### Describe the Bug
   
   发送消息时,偶尔会超时。
   
![WechatIMG2233](https://github.com/user-attachments/assets/4a2451ea-7536-4eef-b34a-0b33fb5f864f)
   
   
   
   ### Steps to Reproduce
   
   请问如何解决该问题
   
   ### What Did You Expect to See?
   
   ERROR,b.c.b.common.rocketmg.service.RocketMaProducer -sendKernelImpl call 
timeout
   
   
   ### What Did You See Instead?
   
   请问如何解决该问题
   
   ### Additional Context
   
   请问如何解决该问题


-- 
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] [Feature] [RIP‐69] Pop Consumption Improvement Based on RocksDB [rocketmq]

2024-12-04 Thread via GitHub


lizhimins opened a new issue, #9025:
URL: https://github.com/apache/rocketmq/issues/9025

   ### Is Your Feature Request Related to a Problem?
   
   Pop consumption is a new consumption model with the advantages of being 
lightweight, stateless on the client side, and non-exclusive queueing in load 
balance. However, the current pop implementation has a large codebase, high 
disk write traffic when the buffer is closed, and more complex state 
maintenance when the buffer is enabled. Therefore, we propose a new 
implementation based on rocksdb storage to elegantly solve the compatibility 
issues between pop retry topic v1 and v2 formats and the probabilistic retry 
access problem. Other improvements include full asynchrony operation, optimized 
cache design, accelerated encoding and decoding, and pop message fairness 
probleam. Performance testing with a read-write ratio of 1:1 in the same 
environment compared to the current mainline (Version 5.3.1), the new pop 
implementation saves 28% of the overall cpu usage of the broker when the buffer 
is closed, and reduces the overall cpu usage by 4.5% when the Buffer is 
enabled, with the pop par
 t showing a reduction of 17%.
   
   ### Describe the Solution You'd Like
   
   As mentioned above, the proposal aims to eliminate the dependency of pop 
consumption on scheduled messages, reduce the codebase and implementation 
complexity, and improve performance to some extent.
   
   ### Describe Alternatives You've Considered
   
   No
   
   ### Additional Context
   
   More details: 
[RIP-59](https://github.com/apache/rocketmq/wiki/%5BRIP%E2%80%9069%5D-Pop-Consumption-Improvement-Based-on-RocksDB)


-- 
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



[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" is working again!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
succeeded.
Run started by GitHub user 3424672656 (triggered by github-actions[bot]).

Head commit for run:
c3b350fb07f56da910343c7a1252c5835ea3e91e / hqbfz 
<125714719+3424672...@users.noreply.github.com>
Merge branch 'apache:develop' into consumer_by_who

Report URL: https://github.com/apache/rocketmq/actions/runs/12172486079

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user AuroraTwinkle (triggered by Jason918).

Head commit for run:
bc66462f4bba2a13ad5510ec5a727ec6936f5c45 / duanlinlin 

add unit test

Report URL: https://github.com/apache/rocketmq/actions/runs/12062550787

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "E2E test for pull request" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user 3424672656 (triggered by 3424672656).

Head commit for run:
f4c498433d19e83510d4181ea9a63fbc7e3115eb / rongtong 

[ISSUE #7480] Fix the offset in the timerCheckPoint will not be corrected when 
the commitlog and consumeQueue are truncated (#7488)

Report URL: https://github.com/apache/rocketmq/actions/runs/12172505714

With regards,
GitHub Actions via GitBox



[PR] createFlushConsumeQueueService for loadAndStartConsumerServiceOnly [rocketmq]

2024-12-04 Thread via GitHub


LetLetMe opened a new pull request, #9026:
URL: https://github.com/apache/rocketmq/pull/9026

   
   
   ### 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



Re: [I] [Bug] 4.9.3版本 出现sendKernelImpl call timeout 这个报错 [rocketmq]

2024-12-04 Thread via GitHub


jinzhiyuan521ping commented on issue #9024:
URL: https://github.com/apache/rocketmq/issues/9024#issuecomment-2519415601

   > 检查服务端或者网络状态,顺序消息发送的时候默认没有重试
   
   都是内网 应用服务器和mq服务器在同一网段。


-- 
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!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
failed.
Run started by GitHub user lizhimins (triggered by github-actions[bot]).

Head commit for run:
01a51231b3e8a0e72b2803d537bfbeb4f8e45719 / Zhanhui Li 
[ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of 
message body (#9016)

Report URL: https://github.com/apache/rocketmq/actions/runs/12174873822

With regards,
GitHub Actions via GitBox



[PR] [ISSUE #878] The java implementation of recalling API [rocketmq-clients]

2024-12-04 Thread via GitHub


imzs opened a new pull request, #879:
URL: https://github.com/apache/rocketmq-clients/pull/879

   [ISSUE #878 ]


-- 
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 Maven" is working again!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
succeeded.
Run started by GitHub user lizhimins (triggered by lizhimins).

Head commit for run:
01a51231b3e8a0e72b2803d537bfbeb4f8e45719 / Zhanhui Li 
[ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of 
message body (#9016)

Report URL: https://github.com/apache/rocketmq/actions/runs/12174873828

With regards,
GitHub Actions via GitBox



Re: [PR] [ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of message body [rocketmq]

2024-12-04 Thread via GitHub


lizhimins merged PR #9016:
URL: https://github.com/apache/rocketmq/pull/9016


-- 
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] Omit message body causes NPE [rocketmq]

2024-12-04 Thread via GitHub


lizhimins closed issue #9015: [Bug] Omit message body causes NPE
URL: https://github.com/apache/rocketmq/issues/9015


-- 
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



(rocketmq) branch develop updated: [ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of message body (#9016)

2024-12-04 Thread lizhimin
This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
 new 01a51231b3 [ISSUE #9015] Sync SysFlag and message body inflation 
status; allow omit of message body (#9016)
01a51231b3 is described below

commit 01a51231b3e8a0e72b2803d537bfbeb4f8e45719
Author: Zhanhui Li 
AuthorDate: Thu Dec 5 15:06:35 2024 +0800

[ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of 
message body (#9016)
---
 .../client/impl/consumer/ProcessQueue.java | 12 --
 .../client/producer/ProduceAccumulator.java| 50 ++
 .../trace/hook/SendMessageOpenTracingHookImpl.java |  6 +--
 .../trace/hook/SendMessageTraceHookImpl.java   |  3 +-
 .../rocketmq/common/message/MessageDecoder.java|  4 +-
 5 files changed, 50 insertions(+), 25 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java
index 33e698b00c..bc1b5eff2f 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java
@@ -137,7 +137,7 @@ public class ProcessQueue {
 if (null == old) {
 validMsgCnt++;
 this.queueOffsetMax = msg.getQueueOffset();
-msgSize.addAndGet(msg.getBody().length);
+msgSize.addAndGet(null == msg.getBody() ? 0 : 
msg.getBody().length);
 }
 }
 msgCount.addAndGet(validMsgCnt);
@@ -198,7 +198,10 @@ public class ProcessQueue {
 MessageExt prev = 
msgTreeMap.remove(msg.getQueueOffset());
 if (prev != null) {
 removedCnt--;
-msgSize.addAndGet(-msg.getBody().length);
+long bodySize = null == msg.getBody() ? 0 : 
msg.getBody().length;
+if (bodySize > 0) {
+msgSize.addAndGet(-bodySize);
+}
 }
 }
 if (msgCount.addAndGet(removedCnt) == 0) {
@@ -270,7 +273,10 @@ public class ProcessQueue {
 msgSize.set(0);
 } else {
 for (MessageExt msg : 
this.consumingMsgOrderlyTreeMap.values()) {
-msgSize.addAndGet(-msg.getBody().length);
+int bodySize = null == msg.getBody() ? 0 : 
msg.getBody().length;
+if (bodySize > 0) {
+msgSize.addAndGet(-bodySize);
+}
 }
 }
 this.consumingMsgOrderlyTreeMap.clear();
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java
 
b/client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java
index 46dfcf71d2..809830e464 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java
@@ -52,9 +52,9 @@ public class ProduceAccumulator {
 private final Logger log = 
LoggerFactory.getLogger(DefaultMQProducer.class);
 private final GuardForSyncSendService guardThreadForSyncSend;
 private final GuardForAsyncSendService guardThreadForAsyncSend;
-private Map syncSendBatchs = new 
ConcurrentHashMap();
-private Map asyncSendBatchs = new 
ConcurrentHashMap();
-private AtomicLong currentlyHoldSize = new AtomicLong(0);
+private final Map syncSendBatchs = new 
ConcurrentHashMap();
+private final Map asyncSendBatchs = new 
ConcurrentHashMap();
+private final AtomicLong currentlyHoldSize = new AtomicLong(0);
 private final String instanceName;
 
 public ProduceAccumulator(String instanceName) {
@@ -70,11 +70,13 @@ public class ProduceAccumulator {
 serviceName = String.format("Client_%s_GuardForSyncSend", 
clientInstanceName);
 }
 
-@Override public String getServiceName() {
+@Override
+public String getServiceName() {
 return serviceName;
 }
 
-@Override public void run() {
+@Override
+public void run() {
 log.info(this.getServiceName() + " service started");
 
 while (!this.isStopped()) {
@@ -115,11 +117,13 @@ public class ProduceAccumulator {
 serviceName = String.format("Client_%s_GuardForAsyncSend", 
clientInstanceName);
 }
 
-@Override public String getServiceName() {
+@Override
+public String getServiceName()

[GH] (rocketmq): Workflow run "PUSH-CI" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "PUSH-CI" on rocketmq.git has failed.
Run started by GitHub user lizhimins (triggered by lizhimins).

Head commit for run:
01a51231b3e8a0e72b2803d537bfbeb4f8e45719 / Zhanhui Li 
[ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of 
message body (#9016)

Report URL: https://github.com/apache/rocketmq/actions/runs/12174873819

With regards,
GitHub Actions via GitBox



[I] [Feature] Implement Recalling API in Java SDK [rocketmq-clients]

2024-12-04 Thread via GitHub


imzs opened a new issue, #878:
URL: https://github.com/apache/rocketmq-clients/issues/878

   ### Programming Language of the Client
   
   Java
   
   ### Is Your Feature Request Related to a Problem?
   
   -
   
   ### Describe the Solution You'd Like
   
   https://github.com/apache/rocketmq-apis/pull/87
   
   The java implementation of recalling API.
   
   ### Describe Alternatives You've Considered
   
   -
   
   ### Additional Context
   
   -


-- 
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] [Feature] Make check expired message interval configurable to reduce the consuming thread block time [rocketmq]

2024-12-04 Thread via GitHub


lizhimins commented on issue #9019:
URL: https://github.com/apache/rocketmq/issues/9019#issuecomment-2519405254

   队列模型里这个是预期内的,cache 中的 min offset 
没有提交,导致看起来延迟很高,运行中实际上不影响后续消息消费,如果叠加负载均衡的影响,会有大量的重复。


-- 
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] 4.9.3版本 出现sendKernelImpl call timeout 这个报错 [rocketmq]

2024-12-04 Thread via GitHub


lizhimins commented on issue #9024:
URL: https://github.com/apache/rocketmq/issues/9024#issuecomment-2519406653

   检查服务端或者网络状态,顺序消息发送的时候默认没有重试


-- 
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] RocketMQ Message hasn't been sent. Caused by The producer service state not OK, CREATE_JUST [rocketmq]

2024-12-04 Thread via GitHub


lizhimins commented on issue #9023:
URL: https://github.com/apache/rocketmq/issues/9023#issuecomment-2519408277

   没有调用 start 初始化导致的,客户端有个状态机


-- 
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!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
failed.
Run started by GitHub user lizhimins (triggered by lizhimins).

Head commit for run:
01a51231b3e8a0e72b2803d537bfbeb4f8e45719 / Zhanhui Li 
[ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of 
message body (#9016)

Report URL: https://github.com/apache/rocketmq/actions/runs/12174873822

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user RongtongJin (triggered by github-actions[bot]).

Head commit for run:
f4c498433d19e83510d4181ea9a63fbc7e3115eb / rongtong 

[ISSUE #7480] Fix the offset in the timerCheckPoint will not be corrected when 
the commitlog and consumeQueue are truncated (#7488)

Report URL: https://github.com/apache/rocketmq/actions/runs/12155238288

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" is working again!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
succeeded.
Run started by GitHub user RongtongJin (triggered by github-actions[bot]).

Head commit for run:
f4c498433d19e83510d4181ea9a63fbc7e3115eb / rongtong 

[ISSUE #7480] Fix the offset in the timerCheckPoint will not be corrected when 
the commitlog and consumeQueue are truncated (#7488)

Report URL: https://github.com/apache/rocketmq/actions/runs/12155238288

With regards,
GitHub Actions via GitBox



[I] [Enhancement] Correct the error message of acl command [rocketmq]

2024-12-04 Thread via GitHub


yx9o opened a new issue, #9021:
URL: https://github.com/apache/rocketmq/issues/9021

   ### Before Creating the Enhancement Request
   
   - [X] I have confirmed that this should be classified as an enhancement 
rather than a bug/feature.
   
   
   ### Summary
   
   When ACL is not enabled, the error messages obtained when executing the 
`deleteAclConfig`, `updateAclConfig`, and `updateGlobalWhiteAddr` commands are 
unclear.
   
   ### Motivation
   
   The error description is null.
   https://github.com/user-attachments/assets/79058601-1d94-4047-b622-bdec2254288b";>
   https://github.com/user-attachments/assets/310d4427-e8a3-4982-92e1-dcf59173927b";>
   https://github.com/user-attachments/assets/cfc3d874-1019-4f50-88ba-0935c0bb0325";>
   
   ### Describe the Solution You'd Like
   
   Returns a detailed error description instead of null.
   
   ### Describe Alternatives You've Considered
   
   No
   
   ### 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



[PR] [ISSUE #9021] Correct the error message of acl command [rocketmq]

2024-12-04 Thread via GitHub


yx9o opened a new pull request, #9022:
URL: https://github.com/apache/rocketmq/pull/9022

   
   Fixes #9021 .
   


-- 
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" is working again!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
succeeded.
Run started by GitHub user yx9o (triggered by github-actions[bot]).

Head commit for run:
2b623ea7f2ca147827d33d04d0acd3cc45db0b23 / yx9o 
[ISSUE #9021] Correct the error message of acl command

Report URL: https://github.com/apache/rocketmq/actions/runs/12163046400

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
failed.
Run started by GitHub user yx9o (triggered by yx9o).

Head commit for run:
2b623ea7f2ca147827d33d04d0acd3cc45db0b23 / yx9o 
[ISSUE #9021] Correct the error message of acl command

Report URL: https://github.com/apache/rocketmq/actions/runs/12163046400

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "E2E test for pull request" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user yx9o (triggered by yx9o).

Head commit for run:
f4c498433d19e83510d4181ea9a63fbc7e3115eb / rongtong 

[ISSUE #7480] Fix the offset in the timerCheckPoint will not be corrected when 
the commitlog and consumeQueue are truncated (#7488)

Report URL: https://github.com/apache/rocketmq/actions/runs/12163090091

With regards,
GitHub Actions via GitBox



Re: [PR] [ISSUE #9021] Correct the error message of acl command [rocketmq]

2024-12-04 Thread via GitHub


codecov-commenter commented on PR #9022:
URL: https://github.com/apache/rocketmq/pull/9022#issuecomment-2517894127

   ## 
[Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/9022?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
 Report
   Attention: Patch coverage is `0%` with `24 lines` in your changes missing 
coverage. Please review.
   > Project coverage is 47.70%. Comparing base 
[(`f4c4984`)](https://app.codecov.io/gh/apache/rocketmq/commit/f4c498433d19e83510d4181ea9a63fbc7e3115eb?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
 to head 
[(`2b623ea`)](https://app.codecov.io/gh/apache/rocketmq/commit/2b623ea7f2ca147827d33d04d0acd3cc45db0b23?dropdown=coverage&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache).
   
   | [Files with missing 
lines](https://app.codecov.io/gh/apache/rocketmq/pull/9022?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
 | Patch % | Lines |
   |---|---|---|
   | 
[...ocketmq/broker/processor/AdminBrokerProcessor.java](https://app.codecov.io/gh/apache/rocketmq/pull/9022?src=pr&el=tree&filepath=broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fapache%2Frocketmq%2Fbroker%2Fprocessor%2FAdminBrokerProcessor.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache#diff-YnJva2VyL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9yb2NrZXRtcS9icm9rZXIvcHJvY2Vzc29yL0FkbWluQnJva2VyUHJvY2Vzc29yLmphdmE=)
 | 0.00% | [24 Missing :warning: 
](https://app.codecov.io/gh/apache/rocketmq/pull/9022?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
 |
   
   Additional details and impacted files
   
   
   ```diff
   @@  Coverage Diff  @@
   ## develop#9022  +/-   ##
   =
   - Coverage  47.77%   47.70%   -0.08% 
   + Complexity 1182011802  -18 
   =
 Files   1305 1305  
 Lines  9138591388   +3 
 Branches   1173611735   -1 
   =
   - Hits   4366143596  -65 
   - Misses 4233342397  +64 
   - Partials5391 5395   +4 
   ```
   
   
   
   [:umbrella: View full report in Codecov by 
Sentry](https://app.codecov.io/gh/apache/rocketmq/pull/9022?dropdown=coverage&src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache).
   
   :loudspeaker: Have feedback on the report? [Share it 
here](https://about.codecov.io/codecov-pr-comment-feedback/?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache).
   


-- 
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 #9012]Optimize RemotingTimeoutException message to print [rocketmq]

2024-12-04 Thread via GitHub


mxsm commented on PR #9013:
URL: https://github.com/apache/rocketmq/pull/9013#issuecomment-2517901318

   @RongtongJin  PTAL


-- 
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 Maven" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user yx9o (triggered by yx9o).

Head commit for run:
2b623ea7f2ca147827d33d04d0acd3cc45db0b23 / yx9o 
[ISSUE #9021] Correct the error message of acl command

Report URL: https://github.com/apache/rocketmq/actions/runs/12163046380

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" is working again!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
succeeded.
Run started by GitHub user yx9o (triggered by github-actions[bot]).

Head commit for run:
2b623ea7f2ca147827d33d04d0acd3cc45db0b23 / yx9o 
[ISSUE #9021] Correct the error message of acl command

Report URL: https://github.com/apache/rocketmq/actions/runs/12163046380

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user RongtongJin (triggered by RongtongJin).

Head commit for run:
f4c498433d19e83510d4181ea9a63fbc7e3115eb / rongtong 

[ISSUE #7480] Fix the offset in the timerCheckPoint will not be corrected when 
the commitlog and consumeQueue are truncated (#7488)

Report URL: https://github.com/apache/rocketmq/actions/runs/12155238288

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "PUSH-CI" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "PUSH-CI" on rocketmq.git has failed.
Run started by GitHub user RongtongJin (triggered by RongtongJin).

Head commit for run:
f4c498433d19e83510d4181ea9a63fbc7e3115eb / rongtong 

[ISSUE #7480] Fix the offset in the timerCheckPoint will not be corrected when 
the commitlog and consumeQueue are truncated (#7488)

Report URL: https://github.com/apache/rocketmq/actions/runs/12155238309

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" is working again!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
succeeded.
Run started by GitHub user lizhimins (triggered by github-actions[bot]).

Head commit for run:
01a51231b3e8a0e72b2803d537bfbeb4f8e45719 / Zhanhui Li 
[ISSUE #9015] Sync SysFlag and message body inflation status; allow omit of 
message body (#9016)

Report URL: https://github.com/apache/rocketmq/actions/runs/12174873822

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "E2E test for pull request" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user AuroraTwinkle (triggered by AuroraTwinkle).

Head commit for run:
f4c498433d19e83510d4181ea9a63fbc7e3115eb / rongtong 

[ISSUE #7480] Fix the offset in the timerCheckPoint will not be corrected when 
the commitlog and consumeQueue are truncated (#7488)

Report URL: https://github.com/apache/rocketmq/actions/runs/12172304007

With regards,
GitHub Actions via GitBox



Re: [PR] fix[slave]:Make SubscriptionGroupConfig and MessageRequestMode updating atomically [rocketmq]

2024-12-04 Thread via GitHub


Jason918 commented on PR #8983:
URL: https://github.com/apache/rocketmq/pull/8983#issuecomment-2518991637

   @AuroraTwinkle Please check the CI result.


-- 
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!

2024-12-04 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
failed.
Run started by GitHub user 3424672656 (triggered by 3424672656).

Head commit for run:
c3b350fb07f56da910343c7a1252c5835ea3e91e / hqbfz 
<125714719+3424672...@users.noreply.github.com>
Merge branch 'apache:develop' into consumer_by_who

Report URL: https://github.com/apache/rocketmq/actions/runs/12172486079

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Coverage" failed!

2024-12-04 Thread GitBox


The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user AuroraTwinkle (triggered by Jason918).

Head commit for run:
bc66462f4bba2a13ad5510ec5a727ec6936f5c45 / duanlinlin 

add unit test

Report URL: https://github.com/apache/rocketmq/actions/runs/12062550796

With regards,
GitHub Actions via GitBox



Re: [I] [Bug] ClientManagerImpl 的 rpcClientTableLock 存在异常网络情况的写锁hang住,导致与broker交互全面阻塞 [rocketmq-clients]

2024-12-04 Thread via GitHub


github-actions[bot] commented on issue #857:
URL: 
https://github.com/apache/rocketmq-clients/issues/857#issuecomment-2518830488

   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.


-- 
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] RocketMQ Message hasn't been sent. Caused by The producer service state not OK, CREATE_JUST [rocketmq]

2024-12-04 Thread via GitHub


lijie123bes opened a new issue, #9023:
URL: https://github.com/apache/rocketmq/issues/9023

   ### 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
   
   4.6.0
   
   ### JDK Version
   
   _No response_
   
   ### Describe the Bug
   
   
![ktsghovnvomwe_96208b870c054871a7a0395bbc8512f1](https://github.com/user-attachments/assets/0a1ecc96-1526-46cd-a449-d9b856ee9341)
   
   
   ### Steps to Reproduce
   
   none
   
   ### What Did You Expect to See?
   
   narmal
   
   ### What Did You See Instead?
   
   RocketMQ Message hasn't been sent. Caused by The producer service state not 
OK, CREATE_JUST
   
   ### 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