MatrixHB commented on issue #4425:
URL: https://github.com/apache/rocketmq/issues/4425#issuecomment-1156050222
Or, you can increase the waiting time limit in send request queue.
`sh mqadmin updateBrokerConfig -b {brokerIP:port} -k
waitTimeMillsInSendQueue -v 3000`
--
This is an aut
tianliuliu commented on PR #4441:
URL: https://github.com/apache/rocketmq/pull/4441#issuecomment-1156039501
It is better to describe like what problem was solved, what was done
tsunghanjacktsai commented on code in PR #4218:
URL: https://github.com/apache/rocketmq/pull/4218#discussion_r897573080
##
broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java:
##
@@ -246,12 +246,6 @@ private RemotingCommand processRequest(final Ch
MatrixHB commented on PR #4439:
URL: https://github.com/apache/rocketmq/pull/4439#issuecomment-1156025177
Related to [https://github.com/apache/rocketmq/issues/4435]( ISSUE #4435)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
liuzongliang0202 opened a new issue, #4463:
URL: https://github.com/apache/rocketmq/issues/4463
Only when the rocketmq indexfile is full can the disk be flushed. If the
indexfile is not full, may the data in the indexfile be lost after normal exit?
For example, after rocketmq exits normally
MatrixHB commented on issue #4451:
URL: https://github.com/apache/rocketmq/issues/4451#issuecomment-1155951974
When executing `if (isOrder && !this.lock(mq))`, the main purpose is to lock
the messageQueue in the server-side, `processQueue.setLocked(true);` is
secondary.
 for Apache RocketMQ has invited Lin
> Shen (apache id: shenlin, github id: 2011shenlin) and Yangkun Ai (apache
> id: aaronai, github id: aaron-ai) to become committers, and we are ple
Hi Apache RocketMQ Community,
The Project Management Committee (PMC) for Apache RocketMQ has invited Lin
Shen (apache id: shenlin, github id: 2011shenlin) and Yangkun Ai (apache
id: aaronai, github id: aaron-ai) to become committers, and we are pleased
to announce that they have accepted.
Congrat
ShannonDing merged PR #841:
URL: https://github.com/apache/rocketmq-client-go/pull/841
--
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: dev-unsubscr...@r
ShannonDing closed issue #823: go1.18 consumer failed to start
URL: https://github.com/apache/rocketmq-client-go/issues/823
--
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 u
hzh0425 commented on issue #4461:
URL: https://github.com/apache/rocketmq/issues/4461#issuecomment-1155890471
> IMO, after changing system properties, it's needed to restart process to
take effect.
yes it is inconvenient
--
This is an automated message from the Apache Git Service.
lizhiboo commented on issue #4461:
URL: https://github.com/apache/rocketmq/issues/4461#issuecomment-1155861314
IMO, after changing system properties, it's needed to restart process to
take effect.
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
mahaitao617 opened a new issue, #4462:
URL: https://github.com/apache/rocketmq/issues/4462
public class TopicPublishInfo {
private boolean orderTopic = false;
private boolean haveTopicRouterInfo = false;
private List messageQueueList = new
ArrayList();
private
hzh0425 commented on PR #4424:
URL: https://github.com/apache/rocketmq/pull/4424#issuecomment-1155211679
问题场景: RoleChange (Controller 选出新的 Leader) 时, Broker 是通过定时任务来 Sync controller
得元数据, 也即会有一个时间间隔. 我们希望减少这个时间间隔, 所以当选出新的 Leader 后, 让 Controller 立即通知相应得 Broker.
--
This is an automated mess
hzh0425 commented on PR #4460:
URL: https://github.com/apache/rocketmq/pull/4460#issuecomment-1155188478
Still have some problems that waiting to found~
--
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
hzh0425 commented on issue #4445:
URL: https://github.com/apache/rocketmq/issues/4445#issuecomment-1155184135
感谢建议
--
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 unsubs
sunxiaojian opened a new pull request, #158:
URL: https://github.com/apache/rocketmq-connect/pull/158
## What is the purpose of the change
X
## Brief changelog
XX
## Verifying this change
Follow this checklist to help us incorporate your cont
fulln opened a new issue, #4461:
URL: https://github.com/apache/rocketmq/issues/4461
need to change the log level dynamicly, we can changed by system properties
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
lizhanhui merged PR #33:
URL: https://github.com/apache/rocketmq-apis/pull/33
--
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: dev-unsubscr...@rocketmq.a
ShannonDing closed issue #832: Client may submit wrong offset when network
instability
URL: https://github.com/apache/rocketmq-client-go/issues/832
--
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 th
ShannonDing merged PR #833:
URL: https://github.com/apache/rocketmq-client-go/pull/833
--
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: dev-unsubscr...@r
yuz10 merged PR #4038:
URL: https://github.com/apache/rocketmq/pull/4038
--
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: dev-unsubscr...@rocketmq.apache
yuz10 closed issue #4037: Admin command to delete expired CommitLog
URL: https://github.com/apache/rocketmq/issues/4037
--
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 unsub
coveralls commented on PR #4460:
URL: https://github.com/apache/rocketmq/pull/4460#issuecomment-1154910694
[](https://coveralls.io/builds/4638)
Coverage increased (+0.02%) to 47.477% when pulling
**41ea3e67d6f648ad
framctr opened a new issue, #105:
URL: https://github.com/apache/rocketmq-exporter/issues/105
RocketMQ exporter does not show metrics comments and some metrics are not
intuitive to understand.
For example, what `rocketmq_brokeruntime_pmdt_0ms` stands for?
**To Reproduce**
St
waney316 commented on issue #104:
URL:
https://github.com/apache/rocketmq-exporter/issues/104#issuecomment-1154898971
you can clone this project and build to docker image
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
codecov-commenter commented on PR #4460:
URL: https://github.com/apache/rocketmq/pull/4460#issuecomment-1154897812
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/4460?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+S
dongeforever commented on PR #4383:
URL: https://github.com/apache/rocketmq/pull/4383#issuecomment-1154883293
@lwclover I have read all the code. This solution is simple and useful in
some cases.
And the same time, there are two potential problems.
Firstly, in the public cloud
2011shenlin merged PR #22:
URL: https://github.com/apache/rocketmq-eventbridge/pull/22
--
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: dev-unsubscr...@r
xixingzhe opened a new issue, #464:
URL: https://github.com/apache/rocketmq-spring/issues/464
代码配置
`@RocketMQMessageListener(topic = "${mq.topic.test-topic}", consumerGroup =
"${mq.topic.test-topic-consumer-group}", namespace =
"${rocketmq.consumer.namespace}")`
报错：
`[ERROR] 2022-0
xixingzhe closed issue #463: namespace报错
URL: https://github.com/apache/rocketmq-spring/issues/463
--
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: dev-u
xixingzhe opened a new issue, #463:
URL: https://github.com/apache/rocketmq-spring/issues/463
代码配置
`@RocketMQMessageListener(topic = "${mq.topic.test-topic}", consumerGroup =
"${mq.topic.test-topic-consumer-group}", namespace =
"${rocketmq.consumer.namespace}")`
报错：
`[ERROR] 2022-0
RongtongJin opened a new pull request, #4460:
URL: https://github.com/apache/rocketmq/pull/4460
## What is the purpose of the change
Controller模式在网络分区场景下，confirmOffset的更新，cq的构建，数据的节点要相互配合，否则会丢死后
## Brief changelog
Update the logic of confirmOffset and recover topicQueueTa
zhouxinyu merged PR #4459:
URL: https://github.com/apache/rocketmq/pull/4459
--
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: dev-unsubscr...@rocketmq.ap
zhouxinyu commented on PR #4459:
URL: https://github.com/apache/rocketmq/pull/4459#issuecomment-1154812196
LGTM~
--
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 unsubscr
39 matches
Mail list logo
