suopovate commented on issue #7355:
URL: https://github.com/apache/rocketmq/issues/7355#issuecomment-1733046350
Why not recover from the minimum cmq physical offset when abnormally
exiting🤔?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
suopovate commented on issue #7355:
URL: https://github.com/apache/rocketmq/issues/7355#issuecomment-1733051875
> Why not recover from the minimum cmq physical offset when abnormally
exiting🤔?
collect all consumer queue last message's commit log physical offset, and
use the minimum
cserwen commented on issue #7355:
URL: https://github.com/apache/rocketmq/issues/7355#issuecomment-1733072839
> > Why not recover from the minimum cmq physical offset when abnormally
exiting🤔?
>
> collect all consumer queue last message's commit log physical offset, and
use the minim
ainokiseki opened a new issue, #610:
URL: https://github.com/apache/rocketmq-clients/issues/610
### 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).
suopovate commented on issue #7355:
URL: https://github.com/apache/rocketmq/issues/7355#issuecomment-1733098334
> > > Why not recover from the minimum cmq physical offset when abnormally
exiting🤔?
> >
> >
> > collect all consumer queue last message's commit log physical offset,
a
cserwen commented on issue #7355:
URL: https://github.com/apache/rocketmq/issues/7355#issuecomment-1733118782
> > > > Why not recover from the minimum cmq physical offset when abnormally
exiting🤔?
> > >
> > >
> > > collect all consumer queue last message's commit log physical offs
ShannonDing merged PR #1099:
URL: https://github.com/apache/rocketmq-client-go/pull/1099
--
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-unsubsc
ShannonDing closed issue #1098: HttpResolver snapshot file will be overwritten
and mixed if multiple consumers or producers use different name server domains
URL: https://github.com/apache/rocketmq-client-go/issues/1098
--
This is an automated message from the Apache Git Service.
To respond t
This is an automated email from the ASF dual-hosted git repository.
dinglei 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 5eab91b fix: snapshot file will be
suopovate commented on issue #7355:
URL: https://github.com/apache/rocketmq/issues/7355#issuecomment-1733138240
> > > > > Why not recover from the minimum cmq physical offset when
abnormally exiting🤔?
> > > >
> > > >
> > > > collect all consumer queue last message's commit log phy
dingshuangxi888 commented on code in PR #7367:
URL: https://github.com/apache/rocketmq/pull/7367#discussion_r1335596568
##
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RocketMQSerializable.java:
##
@@ -202,29 +202,33 @@ private static int calTotalLen(int remark,
dingshuangxi888 commented on code in PR #7367:
URL: https://github.com/apache/rocketmq/pull/7367#discussion_r1335599653
##
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RocketMQSerializable.java:
##
@@ -202,29 +202,33 @@ private static int calTotalLen(int remark,
cserwen merged PR #1077:
URL: https://github.com/apache/rocketmq-client-go/pull/1077
--
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...
cserwen closed issue #1076: The order of Topic routing information will change,
resulting in abnormal sending of sequential messages.
URL: https://github.com/apache/rocketmq-client-go/issues/1076
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
cserwen closed issue #1092: 集群环境下，不同机器获取到同一个topic的消息队列顺序不一致
URL: https://github.com/apache/rocketmq-client-go/issues/1092
--
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 uns
This is an automated email from the ASF dual-hosted git repository.
cserwen 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 da20ee7 [ISSUE #1076] fix: sort To
cserwen commented on issue #1070:
URL:
https://github.com/apache/rocketmq-client-go/issues/1070#issuecomment-1733243026
本仓库的 Go SDK 是基于 Remoting 协议实现的，理论上可以访问 5.x 版本（5.x版本支持 Remoting 和 gRPC 协议）
@twgcode
--
This is an automated message from the Apache Git Service.
To respond to the messa
cserwen closed issue #1070: According to the information in the documentation
(https://rocketmq.apache.org/docs/sdk/01overview), does the SDK in this
repository support the usage of RocketMQ 5.x server?
URL: https://github.com/apache/rocketmq-client-go/issues/1070
--
This is an automated mes
drpmma opened a new issue, #7393:
URL: https://github.com/apache/rocketmq/issues/7393
### Before Creating the Enhancement Request
- [X] I have confirmed that this should be classified as an enhancement
rather than a bug/feature.
### Summary
Add timeout configuration
drpmma opened a new pull request, #7394:
URL: https://github.com/apache/rocketmq/pull/7394
### Which Issue(s) This PR Fixes
Fixes #7393
### Brief Description
### How Did You Test This Change?
--
This is an automated message from the
joeCarf commented on issue #7386:
URL: https://github.com/apache/rocketmq/issues/7386#issuecomment-173377
may be you can assign this to me, I'd like to submit a pr and fix it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has
failed.
Run started by GitHub user drpmma (triggered by drpmma).
Head commit for run:
55afbe55b6599fb47d9e84c63f4fb0ac8c15ccc8 / zhouxiang
Add timeout configuration for grpc server
Report URL: https://github.com/apache
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user drpmma (triggered by drpmma).
Head commit for run:
d7e5c4d1a4e048cd97f0b29a96a0fc575927a03e / guyinyou
<36399867+guyin...@users.noreply.github.com>
[ISSUE #7389] Fix the problem that getLas
codecov-commenter commented on PR #7394:
URL: https://github.com/apache/rocketmq/pull/7394#issuecomment-1733361857
##
[Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7394?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
yihonglei opened a new issue, #7395:
URL: https://github.com/apache/rocketmq/issues/7395
### 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
yihonglei closed issue #7395: [Bug] Rester word is error in
BrokerController#doRegisterBrokerAll method log info,
"BrokerController.LOG.info("BrokerController#doResterBrokerAll: broker has
shutdown, no need to register any more.");"
URL: https://github.com/apache/rocketmq/issues/7395
--
Thi
yihonglei opened a new issue, #7396:
URL: https://github.com/apache/rocketmq/issues/7396
### 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
RapperCL commented on code in PR #7367:
URL: https://github.com/apache/rocketmq/pull/7367#discussion_r1335778681
##
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RocketMQSerializable.java:
##
@@ -202,29 +202,33 @@ private static int calTotalLen(int remark, int ext
fuyou001 commented on code in PR #7301:
URL: https://github.com/apache/rocketmq/pull/7301#discussion_r1335845115
##
controller/src/main/java/org/apache/rocketmq/controller/impl/JRaftController.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
fuyou001 commented on code in PR #7301:
URL: https://github.com/apache/rocketmq/pull/7301#discussion_r1335845115
##
controller/src/main/java/org/apache/rocketmq/controller/impl/JRaftController.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
fuyou001 commented on code in PR #7301:
URL: https://github.com/apache/rocketmq/pull/7301#discussion_r1335845115
##
controller/src/main/java/org/apache/rocketmq/controller/impl/JRaftController.java:
##
@@ -0,0 +1,280 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has
succeeded.
Run started by GitHub user onejimmyboy (triggered by yuz10).
Head commit for run:
1b6ce34948bf0bf8f74b726fd4ca1448a340b585 / wyz0061
The UpdateAccessConfigSubCommand instruction adds descriptions on how to del
caigy merged PR #182:
URL: https://github.com/apache/rocketmq-operator/pull/182
--
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...@rock
This is an automated email from the ASF dual-hosted git repository.
caigy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-operator.git
The following commit(s) were added to refs/heads/master by this push:
new f2d0706 [ISSUE #73] Support mounting
caigy commented on PR #132:
URL:
https://github.com/apache/rocketmq-operator/pull/132#issuecomment-1733671933
integrated in #182
--
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 com
caigy closed pull request #132: 【ISSUE #73】support mounting a configMap to
rocketmq-dashboard
URL: https://github.com/apache/rocketmq-operator/pull/132
--
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 t
The GitHub Actions job "E2E test for pull request" on rocketmq.git has
succeeded.
Run started by GitHub user onejimmyboy (triggered by onejimmyboy).
Head commit for run:
d7e5c4d1a4e048cd97f0b29a96a0fc575927a03e / guyinyou
<36399867+guyin...@users.noreply.github.com>
[ISSUE #7389] Fix the probl
suopovate commented on issue #7355:
URL: https://github.com/apache/rocketmq/issues/7355#issuecomment-1733959552
Hello,I have a question.
If System is exit abnormal, when restart, rocketMq will call
recoverAbnormally() to recover consumerQueue and index data.
So why we need to fix the d
github-actions[bot] commented on issue #5183:
URL: https://github.com/apache/rocketmq/issues/5183#issuecomment-1734630541
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
github-actions[bot] commented on issue #5113:
URL: https://github.com/apache/rocketmq/issues/5113#issuecomment-1734630567
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 t
github-actions[bot] closed issue #5113: AutoSwitchRoleIntegrationTest not stable
URL: https://github.com/apache/rocketmq/issues/5113
--
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 comme
github-actions[bot] commented on issue #4719:
URL: https://github.com/apache/rocketmq/issues/4719#issuecomment-1734630589
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 t
github-actions[bot] closed issue #4719: Remove useless
GetRouteInfoRequestHeader.split constant to ensure compatibility
URL: https://github.com/apache/rocketmq/issues/4719
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
Jashinck commented on issue #152:
URL:
https://github.com/apache/rocketmq-eventbridge/issues/152#issuecomment-1734728988
目前的默认存储介质支持RocketMQ，和是否云上和自建没有关系。
--
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
francisoliverlee opened a new pull request, #7397:
URL: https://github.com/apache/rocketmq/pull/7397
### Which Issue(s) This PR Fixes
Fixes #issue_id
### Brief Description
### How Did You Test This Change?
--
This is an automated mes
codecov-commenter commented on PR #7397:
URL: https://github.com/apache/rocketmq/pull/7397#issuecomment-1734747025
##
[Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7397?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user francisoliverlee (triggered by francisoliverlee).
Head commit for run:
a9b3bd5fa08ddf7be307a53bb1026642d8ab5370 / tiger lee <1026203...@qq.com>
remove unused import
Report URL: https://
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
succeeded.
Run started by GitHub user drpmma (triggered by drpmma).
Head commit for run:
a52b6e54fe1643b8c6a07f86fdfe71c9a2c77b95 / zhouxiang
Add proxyConfig
Report URL: https://github.com/apache/rocketmq/actions/runs/
shirenchuang opened a new issue, #7398:
URL: https://github.com/apache/rocketmq/issues/7398
### 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]
joeCarf commented on issue #7386:
URL: https://github.com/apache/rocketmq/issues/7386#issuecomment-1734850312
Why is this a bug? I don't get it. I think the condition
`System.currentTimeMillis() - Long.parseLong(consumeStartTimeStamp)` will be
calculated before the compare, even without the
joeCarf commented on issue #7398:
URL: https://github.com/apache/rocketmq/issues/7398#issuecomment-1734854420
BTW, may I ask how you execute terminal commands like `ExportConfigsCommand`
when debugging RocketMQ in Idea? Thanks a lot~
--
This is an automated message from the Apache Git Ser
shirenchuang opened a new pull request, #7399:
URL: https://github.com/apache/rocketmq/pull/7399
### Which Issue(s) This PR Fixes
Fixes #7398
### Brief Description
### How Did You Test This Change?
--
This is an automated message fr
shirenchuang commented on issue #7398:
URL: https://github.com/apache/rocketmq/issues/7398#issuecomment-1734860901
> BTW, may I ask how you execute terminal commands like
`ExportConfigsCommand` when debugging RocketMQ in Idea? Thanks a lot~
直接跑源码debug 或者 执行sh脚本的时候开启远程端口然后再IDEA调试都可以的
shirenchuang commented on issue #7398:
URL: https://github.com/apache/rocketmq/issues/7398#issuecomment-1734866543
> BTW，请问`ExportConfigsCommand`在Idea中调试RocketMQ时如何执行终端命令？非常感谢~
你可以在 MQAdminStartup的main方法中添加一些参数
```java
public static void main(String[] args) {
S
drpmma merged PR #7394:
URL: https://github.com/apache/rocketmq/pull/7394
--
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.a
drpmma closed issue #7393: [Enhancement] Add timeout configuration for grpc
server
URL: https://github.com/apache/rocketmq/issues/7393
--
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 co
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 3fd43353fd [ISSUE #7393] Add timeout conf
codecov-commenter commented on PR #7399:
URL: https://github.com/apache/rocketmq/pull/7399#issuecomment-1734878112
##
[Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7399?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
joeCarf commented on issue #7398:
URL: https://github.com/apache/rocketmq/issues/7398#issuecomment-1734882557
> > BTW，请问`ExportConfigsCommand`在Idea中调试RocketMQ时如何执行终端命令？非常感谢~
>
> 你可以在 MQAdminStartup的main方法中添加一些参数
>
> ```java
> public static void main(String[] args) {
>
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user shirenchuang (triggered by shirenchuang).
Head commit for run:
0b07733b77991458dda7d65c65bfaeac39c2e29a / 石臻臻
fix bug #7398 ExportConfigsCommand NPE
Report URL: https://github.com/apac
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
failed.
Run started by GitHub user francisoliverlee (triggered by RongtongJin).
Head commit for run:
a9b3bd5fa08ddf7be307a53bb1026642d8ab5370 / tiger lee <1026203...@qq.com>
remove unused import
Report URL: https://githu
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
succeeded.
Run started by GitHub user drpmma (triggered by drpmma).
Head commit for run:
3fd43353fdf880deb5d63ba3ad50cc6e3259dc3a / Zhouxiang Zhan
[ISSUE #7393] Add timeout configuration for grpc server (#7394)
* Add ti
onejimmyboy commented on PR #7368:
URL: https://github.com/apache/rocketmq/pull/7368#issuecomment-1734912667
> suggest name this pr like `[ISSUE #xxx] x`
ok
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
shirenchuang opened a new issue, #7400:
URL: https://github.com/apache/rocketmq/issues/7400
### 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]
64 matches
Mail list logo
