[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 drpmma (triggered by drpmma). Head commit for run: 000c47bdf01ff0f50db5044a32fb22fda42c0ba6 / zhouxiang Set enableTrace default to false Report URL: https://github.com/apache/rocketmq/actions/runs/8642486871 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" is working again!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has succeeded. Run started by GitHub user drpmma (triggered by lollipopjin). Head commit for run: 000c47bdf01ff0f50db5044a32fb22fda42c0ba6 / zhouxiang Set enableTrace default to false Report URL: https://github.com/apache/rocketmq/actions/runs/8642486871 With regards, GitHub Actions via GitBox
Re: [I] When the master node of RocketMQ 5.1.4 version crashes, scheduled messages cannot be delivered normally [rocketmq]
gaoyf commented on issue #8006: URL: https://github.com/apache/rocketmq/issues/8006#issuecomment-2049347862 > My deployment architecture is master-slave mode. After the master node goes down, what solutions are available in master-slave mode to enable the slave to continue sending scheduled messages normally? FYI：https://github.com/apache/rocketmq/blob/develop/docs/cn/SlaveActingMasterMode.md -- 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-client-nodejs是真的有测试通过后发布的吗 [rocketmq-clients]
drpmma commented on issue #723: URL: https://github.com/apache/rocketmq-clients/issues/723#issuecomment-2049431870 This issue is not related to this repository, please submit issue in the corresponding [repository](https://github.com/apache/rocketmq-client-nodejs). -- 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 #7988] Set enableTrace default to false [rocketmq]
drpmma merged PR #8015: URL: https://github.com/apache/rocketmq/pull/8015 -- 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 #7988] Set enableTrace default to false
This is an automated email from the ASF dual-hosted git repository.
zhouxzhan 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 528ae847e2 [ISSUE #7988] Set enableTrace default to false
528ae847e2 is described below
commit 528ae847e28714e4fff250517354ba51d885e562
Author: Zhouxiang Zhan
AuthorDate: Thu Apr 11 19:13:27 2024 +0800
[ISSUE #7988] Set enableTrace default to false
---
client/src/main/java/org/apache/rocketmq/client/ClientConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
index 48c995301a..0fc04fcccb 100644
--- a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
+++ b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
@@ -101,7 +101,7 @@ public class ClientConfig {
/**
* The switch for message trace
*/
-protected boolean enableTrace = true;
+protected boolean enableTrace = false;
/**
* The name value of message trace topic. If not set, the default trace
topic name will be used.
[I] [Enhancement] Add test module to provide integration test for java client [rocketmq-clients]
drpmma opened a new issue, #726: URL: https://github.com/apache/rocketmq-clients/issues/726 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Programming Language of the Client Java ### Summary Add test module to provide integration test for java client. ### Motivation Add test module to provide integration test for java client. ### Describe the Solution You'd Like Add GrpcServerIntegrationTest and AttemptIdIntegrationTest. ### 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 #726] Add test module to provide integration test for java client [rocketmq-clients]
drpmma opened a new pull request, #727: URL: https://github.com/apache/rocketmq-clients/pull/727 ### Which Issue(s) This PR Fixes Fixes #726 ### Brief Description Add test module to provide integration test for java client ### 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-clients): Workflow run "Java Coverage" failed!
The GitHub Actions job "Java Coverage" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 99a2f4b072decf67633063b815094e7ed5abb14d / zhouxiang Add AttemptIdIntegrationTest Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8645816343 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "License Checker" failed!
The GitHub Actions job "License Checker" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 99a2f4b072decf67633063b815094e7ed5abb14d / zhouxiang Add AttemptIdIntegrationTest Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8645816344 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Java Coverage" failed!
The GitHub Actions job "Java Coverage" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 912f4db910b19a13261094f0dd402bc21ac3f4fd / zhouxiang fix package Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8645853828 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 99a2f4b072decf67633063b815094e7ed5abb14d / zhouxiang Add AttemptIdIntegrationTest Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8645816383 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "License Checker" failed!
The GitHub Actions job "License Checker" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 912f4db910b19a13261094f0dd402bc21ac3f4fd / zhouxiang fix package Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8645853826 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "License Checker" failed!
The GitHub Actions job "License Checker" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 99729b09b68dae37cc33601bf072f69a98ebe731 / zhouxiang Add license Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8645871253 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Java Coverage" failed!
The GitHub Actions job "Java Coverage" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 99729b09b68dae37cc33601bf072f69a98ebe731 / zhouxiang Add license Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8645871255 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 912f4db910b19a13261094f0dd402bc21ac3f4fd / zhouxiang fix package Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8645853868 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 99729b09b68dae37cc33601bf072f69a98ebe731 / zhouxiang Add license Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8645871309 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "PUSH-CI" failed!
The GitHub Actions job "PUSH-CI" on rocketmq.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 528ae847e28714e4fff250517354ba51d885e562 / Zhouxiang Zhan [ISSUE #7988] Set enableTrace default to false Report URL: https://github.com/apache/rocketmq/actions/runs/8645779673 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 drpmma (triggered by drpmma). Head commit for run: 528ae847e28714e4fff250517354ba51d885e562 / Zhouxiang Zhan [ISSUE #7988] Set enableTrace default to false Report URL: https://github.com/apache/rocketmq/actions/runs/8645779664 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 drpmma (triggered by drpmma). Head commit for run: 528ae847e28714e4fff250517354ba51d885e562 / Zhouxiang Zhan [ISSUE #7988] Set enableTrace default to false Report URL: https://github.com/apache/rocketmq/actions/runs/8645779670 With regards, GitHub Actions via GitBox
Re: [I] 不支持5.1版本吧 [rocketmq-exporter]
iamqq23ue commented on issue #164: URL: https://github.com/apache/rocketmq-exporter/issues/164#issuecomment-2049617962 @caigy ，谢谢，试了5.2.0，确实指标多了。不过好像还是少了一些，比如写入时间1ms,10ms数量这种指标 -- 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] Memory leakage detected when IndexStoreService is enabled and TieredMessageStore's FileSegment is PosixFileSegment [rocketmq]
bxfjb opened a new issue, #8017:
URL: https://github.com/apache/rocketmq/issues/8017
### 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
branch: develop
### JDK Version
OpenJDK 8
### Describe the Bug
We deployed a rocketmq cluster with TieredStore and offload cold data to hdd
with PosixFileSegment. After about 16 hours of producing messages, the
shutdownHook was called and there is no other error log.
> 2024-04-11 09:57:22 INFO ShutdownHook - Shutdown hook was invoked, 1
By checking monitor, we found out that the direct memory usage kept on
increasing in a stable rate,
which reminds us of checking if there is memory leak. Actually the increase
rate is a direct clue -- about 570 MB each time, exactly the size of a
compacted IndexFile, which leads us to here at `IndexStoreService.java`:
```
public boolean doCompactThenUploadFile(IndexFile indexFile) {
...
boolean result = flatAppendFile.commitAsync().join();
...
}
```
Add a watch of direct memory when debugging the UT `doCompactionTest` at
`IndexStoreServiceTest.java` can prove that `doCompactThenUploadFile` may cause
direct memory leak.
By diving in the code, the root cause actually is inappropriate use of
FileChannel at `PosixFileSegment.java`:
```
@Override
@SuppressWarnings("ResultOfMethodCallIgnored")
public CompletableFuture commit0(
FileSegmentInputStream inputStream, long position, int length,
boolean append) {
return CompletableFuture.supplyAsync(() -> {
try {
byte[] byteArray = ByteStreams.toByteArray(inputStream);
writeFileChannel.position(position);
ByteBuffer buffer = ByteBuffer.wrap(byteArray);
while (buffer.hasRemaining()) {
writeFileChannel.write(buffer);
}
writeFileChannel.force(true);
} catch (Exception e) {
return false;
}
return true;
}, MessageStoreExecutor.getInstance().bufferCommitExecutor);
}
```
The line `writeFileChannel.write(buffer);` would allocate a DirectByteBuffer
whose size is same with `buffer`, which means in uploading of IndexFile, the
DirectByteBuffer's size will be about 570MB. This DirectByteBuffer is an
element of an array of ByteBuffer of a ThreadLocal variable in :
### Steps to Reproduce
2 choices:
1. Deploy a rocketmq cluster with TieredStore and offload cold data to hdd
with PosixFileSegment, keep on producing new messages and the direct memory
usage should increase unlimitedly.
2. Or run IndexStoreServiceTest.doCompactionTest and keep an eye on the
direct buffer usage.
### What Did You Expect to See?
The direct memory usage should not increase unlimitedly.
### What Did You See Instead?
The direct memory usage keeps on increasing until OOM or all threads in
commitExecutor run commit0 at least once.
### 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] feat: use openssl SSL provider to create TLS/SSL engine, adding netty… [rocketmq-mqtt]
lizhanhui opened a new pull request, #256: URL: https://github.com/apache/rocketmq-mqtt/pull/256 …-tcnative to cs module -- 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] Message may be lost when sendMessageBack fails [rocketmq-client-go]
lizhanhui closed issue #1106: Message may be lost when sendMessageBack fails URL: https://github.com/apache/rocketmq-client-go/issues/1106 -- 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-client-go) branch master updated: Send retry as a normal message when sendMessageBack fails (#1107)
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 0e19ee6 Send retry as a normal message when sendMessageBack fails
(#1107)
0e19ee6 is described below
commit 0e19ee654819bda396a08d950c883f9008b8222b
Author: Liu Shengzhong
AuthorDate: Thu Apr 11 23:59:05 2024 +0800
Send retry as a normal message when sendMessageBack fails (#1107)
---
consumer/consumer.go | 96 +++
consumer/pull_consumer.go | 8 +++-
consumer/push_consumer.go | 7 ++--
3 files changed, 106 insertions(+), 5 deletions(-)
diff --git a/consumer/consumer.go b/consumer/consumer.go
index 4ed4940..bbb5415 100644
--- a/consumer/consumer.go
+++ b/consumer/consumer.go
@@ -20,6 +20,7 @@ package consumer
import (
"context"
"fmt"
+ "math/rand"
"sort"
"strconv"
"strings"
@@ -57,6 +58,9 @@ const (
// Offset persistent interval for consumer
_PersistConsumerOffsetInterval = 5 * time.Second
+
+ // Timeout for sending message to retry topic
+ _SendMessageBackAsNormalTimeout = 3 * time.Second
)
type ConsumeType string
@@ -66,6 +70,8 @@ const (
_PushConsume = ConsumeType("CONSUME_PASSIVELY")
_SubAll = "*"
+
+ _ClientInnerProducerGroup = "CLIENT_INNER_PRODUCER"
)
// Message model defines the way how messages are delivered to each consumer
clients.
@@ -1037,6 +1043,96 @@ func (dc *defaultConsumer) searchOffsetByTimestamp(mq
*primitive.MessageQueue, t
return strconv.ParseInt(response.ExtFields["offset"], 10, 64)
}
+func (dc *defaultConsumer) sendMessageBackAsNormal(msg *primitive.MessageExt,
maxReconsumeTimes int32) bool {
+ retryTopic := internal.GetRetryTopic(dc.consumerGroup)
+ normalMsg := &primitive.Message{
+ Topic: retryTopic,
+ Body: msg.Body,
+ Flag: msg.Flag,
+ }
+ normalMsg.WithProperties(msg.GetProperties())
+ originMsgId := msg.GetProperty(primitive.PropertyOriginMessageId)
+ if len(originMsgId) == 0 {
+ originMsgId = msg.MsgId
+ }
+ normalMsg.WithProperty(primitive.PropertyOriginMessageId, originMsgId)
+ normalMsg.WithProperty(primitive.PropertyRetryTopic, msg.Topic)
+ normalMsg.RemoveProperty(primitive.PropertyTransactionPrepared)
+ normalMsg.WithDelayTimeLevel(int(3 + msg.ReconsumeTimes))
+
+ mq, err := dc.findPublishMessageQueue(retryTopic)
+ if err != nil {
+ rlog.Warning("sendMessageBackAsNormal find publish message
queue error", map[string]interface{}{
+ rlog.LogKeyTopic: retryTopic,
+ rlog.LogKeyMessageId: msg.MsgId,
+ rlog.LogKeyUnderlayError: err.Error(),
+ })
+ return false
+ }
+
+ brokerAddr := dc.client.GetNameSrv().FindBrokerAddrByName(mq.BrokerName)
+ if len(brokerAddr) == 0 {
+ rlog.Warning("sendMessageBackAsNormal cannot find broker
address", map[string]interface{}{
+ rlog.LogKeyMessageId: msg.MsgId,
+ rlog.LogKeyBroker:mq.BrokerName,
+ rlog.LogKeyUnderlayError: err.Error(),
+ })
+ return false
+ }
+
+ request := buildSendToRetryRequest(mq, normalMsg, msg.ReconsumeTimes+1,
maxReconsumeTimes)
+ resp, err := dc.client.InvokeSync(context.Background(), brokerAddr,
request, _SendMessageBackAsNormalTimeout)
+ if err != nil {
+ rlog.Warning("sendMessageBackAsNormal failed to invoke",
map[string]interface{}{
+ rlog.LogKeyTopic: retryTopic,
+ rlog.LogKeyMessageId: msg.MsgId,
+ rlog.LogKeyBroker:brokerAddr,
+ rlog.LogKeyUnderlayError: err.Error(),
+ })
+ return false
+ }
+ if resp.Code != internal.ResSuccess {
+ rlog.Warning("sendMessageBackAsNormal failed to send",
map[string]interface{}{
+ rlog.LogKeyTopic: retryTopic,
+ rlog.LogKeyMessageId: msg.MsgId,
+ rlog.LogKeyBroker:brokerAddr,
+ rlog.LogKeyUnderlayError: fmt.Errorf("CODE: %d, DESC:
%s", resp.Code, resp.Remark),
+ })
+ return false
+ }
+
+ return true
+}
+
+func (dc *defaultConsumer) findPublishMessageQueue(topic string)
(*primitive.MessageQueue, error) {
+ mqs, err := dc.client.GetNameSrv().FetchPublishMessageQueues(topic)
+ if err != nil {
+ return nil, err
+ }
+
+ if len(mqs) <= 0 {
+ return nil, fmt.Erro
Re: [PR] feat: use openssl SSL provider to create TLS/SSL engine, adding netty… [rocketmq-mqtt]
lizhanhui merged PR #256: URL: https://github.com/apache/rocketmq-mqtt/pull/256 -- 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 #1106] Send retry as a normal message when sendMessageBack fails [rocketmq-client-go]
lizhanhui merged PR #1107: URL: https://github.com/apache/rocketmq-client-go/pull/1107 -- 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 #1106] Send retry as a normal message when sendMessageBack fails [rocketmq-client-go]
lizhanhui commented on PR #1107: URL: https://github.com/apache/rocketmq-client-go/pull/1107#issuecomment-2050027268 @leizhiyuan The behavior is aligning with Java counterparts, merged. -- 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-mqtt) 01/01: Merge pull request #256 from lizhanhui/openssl
This is an automated email from the ASF dual-hosted git repository. lizhanhui pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git commit 648b73ec0088e18a823cac0293ef01763b1b05fe Merge: 7b556f9 e68ee8e Author: Zhanhui Li AuthorDate: Fri Apr 12 00:01:13 2024 +0800 Merge pull request #256 from lizhanhui/openssl feat: use openssl SSL provider to create TLS/SSL engine, adding netty… mqtt-cs/pom.xml | 6 +- .../java/org/apache/rocketmq/mqtt/cs/protocol/ssl/SslFactory.java | 8 +++- pom.xml | 7 --- 3 files changed, 16 insertions(+), 5 deletions(-)
(rocketmq-mqtt) branch main updated (7b556f9 -> 648b73e)
This is an automated email from the ASF dual-hosted git repository. lizhanhui pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git from 7b556f9 Merge pull request #218 from apache/develop add e68ee8e feat: use openssl SSL provider to create TLS/SSL engine, adding netty-tcnative to cs module new 648b73e Merge pull request #256 from lizhanhui/openssl The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: mqtt-cs/pom.xml | 6 +- .../java/org/apache/rocketmq/mqtt/cs/protocol/ssl/SslFactory.java | 8 +++- pom.xml | 7 --- 3 files changed, 16 insertions(+), 5 deletions(-)
[PR] [ISSUE #8007]fix abnormally recover index file [rocketmq]
3424672656 opened a new pull request, #8018: URL: https://github.com/apache/rocketmq/pull/8018 Avoid crashes and retain the last file and switch new file to putkey. Add a list correct scan check to prevent endless loops caused by file corruption, when an error is checked, messages before this message will be discarded, and set the preIndexNo of this message to -1 -- 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 "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 3424672656 (triggered by 3424672656). Head commit for run: 528ae847e28714e4fff250517354ba51d885e562 / Zhouxiang Zhan [ISSUE #7988] Set enableTrace default to false Report URL: https://github.com/apache/rocketmq/actions/runs/8651035465 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 3424672656 (triggered by 3424672656). Head commit for run: aca477b13be8e3143374d45a713a14a63884e981 / wanghuaiyuan <3424672...@qq.com> fix abnormally recover index file Report URL: https://github.com/apache/rocketmq/actions/runs/8651011040 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 3424672656 (triggered by 3424672656). Head commit for run: aca477b13be8e3143374d45a713a14a63884e981 / wanghuaiyuan <3424672...@qq.com> fix abnormally recover index file Report URL: https://github.com/apache/rocketmq/actions/runs/8651011048 With regards, GitHub Actions via GitBox
Re: [I] DefaultMQProducer.request() sync invoke time out [rocketmq]
github-actions[bot] commented on issue #6574: URL: https://github.com/apache/rocketmq/issues/6574#issuecomment-2050744390 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] rocketmq5.0 delayed message push delayed serious issues [rocketmq]
github-actions[bot] commented on issue #6566: URL: https://github.com/apache/rocketmq/issues/6566#issuecomment-2050744411 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] mqadmin can't resend message through queryMsgById subcommand [rocketmq]
github-actions[bot] commented on issue #6565: URL: https://github.com/apache/rocketmq/issues/6565#issuecomment-2050744431 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] changed code of REGISTER_TOPIC_IN_NAMESRV to 1217 [rocketmq]
github-actions[bot] commented on PR #6514: URL: https://github.com/apache/rocketmq/pull/6514#issuecomment-2050744516 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] The cpu100% problem: occurs when the traffic is heavy and the number of Consumerqueues is small. [rocketmq]
github-actions[bot] commented on issue #6350: URL: https://github.com/apache/rocketmq/issues/6350#issuecomment-2050744615 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] back-incompatible the RequestCode(`REGISTER_TOPIC_IN_NAMESRV`) with `217` value [rocketmq]
github-actions[bot] commented on issue #5768: URL: https://github.com/apache/rocketmq/issues/5768#issuecomment-2050744667 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] Fix DefaultMQProducer#request send message callback timeout problem [rocketmq]
github-actions[bot] commented on issue #6555: URL: https://github.com/apache/rocketmq/issues/6555#issuecomment-2050744464 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] [ISSUE #6456] Fix ConsumeMessageService#updateCorePoolSize: Can not i… [rocketmq]
github-actions[bot] commented on PR #6457: URL: https://github.com/apache/rocketmq/pull/6457#issuecomment-2050744545 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: [PR] [ISSUE #6205] Support Async pull for DefaultLitePullConsumer [rocketmq]
github-actions[bot] commented on PR #6417: URL: https://github.com/apache/rocketmq/pull/6417#issuecomment-2050744580 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] back-incompatible the RequestCode(`REGISTER_TOPIC_IN_NAMESRV`) with `217` value [rocketmq]
github-actions[bot] closed issue #5768: back-incompatible the RequestCode(`REGISTER_TOPIC_IN_NAMESRV`) with `217` value URL: https://github.com/apache/rocketmq/issues/5768 -- 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] ERROR: GetTransport of:xxx get timed_mutex timeout 解决办法 [rocketmq-client-cpp]
naah69 commented on issue #456: URL: https://github.com/apache/rocketmq-client-cpp/issues/456#issuecomment-2050788645 [rocketmq-client-cpp-2.2.0.amd64.deb.zip](https://github.com/apache/rocketmq-client-cpp/files/14952825/rocketmq-client-cpp-2.2.0.amd64.deb.zip) 新编译的版本 -- 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] fix rpm build bug [rocketmq-client-cpp]
naah69 opened a new pull request, #467:
URL: https://github.com/apache/rocketmq-client-cpp/pull/467
fix build bug
```log
error: failed to create directory %{_specdir}: /root/rpmbuild/SPECS:
没有那个文件或目录
cp: 无法获取'/root/rpmbuild/RPMS/x86_64/*.rpm' 的文件状态(stat): 没有那个文件或目录
```
## What is the purpose of the change
X
## Brief changelog
XX
## Verifying this change
Follow this checklist to help us incorporate your contribution quickly and
easily. Notice, `it would be helpful if you could finish the following 5
checklist(the last one is not necessary)before request the community to review
your PR`.
- [x] Make sure there is a [Github
issue](https://github.com/apache/rocketmq/issues) filed for the change (usually
before you start working on it). Trivial changes like typos do not require a
Github issue. Your pull request should address just this issue, without pulling
in other changes - one PR resolves one issue.
- [x] Format the pull request title like `[ISSUE #123] Fix UnknownException
when host config not exist`. Each commit in the pull request should have a
meaningful subject line and body.
- [x] Write a pull request description that is detailed enough to understand
what the pull request does, how, and why.
- [x] Write necessary unit-test(over 80% coverage) to verify your logic
correction, more mock a little better when a cross-module dependency exists.
- [ ] If this contribution is large, please file an [Apache Individual
Contributor License Agreement](http://www.apache.org/licenses/#clas).
--
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] Memory leakage detected when IndexStoreService is enabled and TieredMessageStore's FileSegment is PosixFileSegment [rocketmq]
bxfjb commented on issue #8017: URL: https://github.com/apache/rocketmq/issues/8017#issuecomment-2050833382 Or we can introduce a DirectByteBuffer pool like TransientStorePool -- 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-client-nodejs是真的有测试通过后发布的吗 [rocketmq-clients]
lizhanhui commented on issue #723: URL: https://github.com/apache/rocketmq-clients/issues/723#issuecomment-2050845933 > 我感觉是完全没有测试过，很基础的问题存在，想直接用起来根本不可能，可能他们只想支持java。 倒是我在测试，发现问题再提给他们，但是解不解决也是看他们心情。 我用的是cpp版本。 1. 代码, 测试代码都在仓库里面, 不需要"我感觉是完全没有测试过"; 2. "很基础的问题存在，想直接用起来根本不可能", 这份代码在[钉钉](http://www.52im.net/thread-4106-1-1.html)运行三年多了, 也有一些别的企业在生产上使用. 3. "可能他们只想支持java" 你对社区的基本发展方向缺乏基本的了解. 4. "倒是我在测试，发现问题再提给他们，但是解不解决也是看他们心情" 你只是提了个疑似点, 是否是bug还需要进一步确认; 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: [I] 当判断 isInMem 为false时，只能拉到maxTransferCountOnMessageInDisk条，不满足32条。导致不会继续生成PullEvent，不拉取新消息，消息丢失。 [rocketmq-mqtt]
DongyuanPan commented on issue #255: URL: https://github.com/apache/rocketmq-mqtt/issues/255#issuecomment-2050855343 > 当isInMem 为true，受到MaxTransferBytesOnMessageInMemory的限制，可能导致一次无法拉满32条。 当isInMem为false，受到MaxTransferBytesOnMessageInDisk和MaxTransferCountOnMessageInDisk的限制，无法拉满32条。 是的，这里会无法继续去拉取，可以提交PR修复一下。可以直接在拉取任务的地方判断一下 pullResult.getMessageList().size() >= Math.min(count, 8) -- 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] Error: 1 CANCELLED: Call cancelled from nodejs-client [rocketmq-clients]
drpmma commented on issue #721: URL: https://github.com/apache/rocketmq-clients/issues/721#issuecomment-2050860747 @fengmk2 please have a look -- 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-clients): Workflow run "License Checker" failed!
The GitHub Actions job "License Checker" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 3d3454191e95d9abdbccfec461b82fef5a5fcf16 / zhouxiang fix checkstyle Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8656233696 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Java Coverage" failed!
The GitHub Actions job "Java Coverage" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 3d3454191e95d9abdbccfec461b82fef5a5fcf16 / zhouxiang fix checkstyle Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8656233697 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 3d3454191e95d9abdbccfec461b82fef5a5fcf16 / zhouxiang fix checkstyle Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8656233723 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "License Checker" is working again!
The GitHub Actions job "License Checker" on rocketmq-clients.git has succeeded. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 410b6ff3999272ddaff99cc1199595dc04fb70a1 / zhouxiang fix pom license Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8656482764 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Java Coverage" failed!
The GitHub Actions job "Java Coverage" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 410b6ff3999272ddaff99cc1199595dc04fb70a1 / zhouxiang fix pom license Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8656482777 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user drpmma (triggered by drpmma). Head commit for run: 410b6ff3999272ddaff99cc1199595dc04fb70a1 / zhouxiang fix pom license Report URL: https://github.com/apache/rocketmq-clients/actions/runs/8656482784 With regards, GitHub Actions via GitBox
Re: [I] Error: 1 CANCELLED: Call cancelled from nodejs-client [rocketmq-clients]
fengmk2 commented on issue #721: URL: https://github.com/apache/rocketmq-clients/issues/721#issuecomment-2050907941 重现方式能否提供一下？ -- 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] consumer stuck in rebalance and doesn't consume messsages [rocketmq-client-cpp]
naah69 commented on issue #293: URL: https://github.com/apache/rocketmq-client-cpp/issues/293#issuecomment-2050991644 > commit [5629226](https://github.com/apache/rocketmq-client-cpp/commit/5629226997fea8bc6ac91e9481d2140d983106a7) 解决队列堵塞问题后，导致消费者重复消费 @ShannonDing 基于master编译后，我们也出现这个问题了  -- 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] Master broker in Dledger mode didn't sync consume offset in time after reboot, which caused consume repeatedly [rocketmq]
bxfjb commented on issue #7790: URL: https://github.com/apache/rocketmq/issues/7790#issuecomment-2051056211 > when the master switches，We also encountered the same problem of repeated consumption，Is there other method to avoid this issue before patch become merged Nothing usable yet, you may merge the patch to your personal repository -- 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] DefaultMQProducer.request() sync invoke time out [rocketmq]
haiyanghan closed issue #6574: DefaultMQProducer.request() sync invoke time out URL: https://github.com/apache/rocketmq/issues/6574 -- 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] The last index file should not be deleted when the broker recovers abnormally [rocketmq]
3424672656 commented on issue #8007: URL: https://github.com/apache/rocketmq/issues/8007#issuecomment-205069 link pr 8018[https://github.com/apache/rocketmq/pull/8018] -- 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
