opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity
7,897 Commits 73 Branches 40 Tags
390070159ba2bf9851bbe39e1d6600db7aa8d28e
Commit Graph
7897 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
Lobo Xuandloboxu 390070159b [ISSUE #6235] Removed the ForwardRequestProcessors class that is not being used 
Co-authored-by: loboxu <loboxu@tencent.com>
 2023-03-08 21:55:57 +08:00
hardyfish 5c45294c45 [ISSUE #6189] Replace ThreadFactory create (#6190) 
* Replace ThreadFactory create

* delete unnecessary imports

* remove useless import

* reformat code
 2023-03-08 20:24:30 +08:00
rongtong 9e0fb1b029 [ISSUE #6169] Fix NPE when timerWheel disabled (#6184) 
* Fix some NPE when timerWheel disabled

* Add UT
 2023-03-08 17:23:06 +08:00
Lei Zhiyuan 61c4ba5009 [ISSUE #6213] fix: when subscriptionGroupConfig is null ,we do not register consumer 2023-03-08 16:06:28 +08:00
mxsm 98d8988abc [ISSUE #6133]Update the version information to 5.1.0 in README.md (#6134) 2023-03-08 16:06:04 +08:00
Zhouxiang Zhan 1986c6bdf9 [ISSUE #6207] Use static subscription to calculate consumer lag and latency 
* Fix retryTopicPerm in ConsumerLagCalculator

* [ISSUE #6206] Use static subscription to calculate consumer lag and latency

* Add version for SimpleSubscriptionData

* Fix hashcode and equals for SubscriptionGroupConfig

* remove brokerId in equal and hashcode method

* Add getter setter for version

* fix consumerGroupInfo and getSubscriptionDataSet npe
 2023-03-08 15:47:20 +08:00
Aaron Ai afe6781be6 Remove rbe_default digest check 2023-03-08 14:08:06 +08:00
lk 2b42e16480 [ISSUE #6266] get MessageId from UNIQ_KEY firstly when build system message (#6267) 2023-03-08 09:46:49 +08:00
yuz10 4af6c768fc [ISSUE #6157] Fix incompatibility between 4.x and 5.x in message trace 2023-03-07 08:39:37 +08:00
Aaron Ai 236d4a164e Apply AsyncAppender for broker 2023-03-06 22:20:47 +08:00
Aaron Ai 9214c69d83 Remove unnecessary property[append] for ConsoleAppender 2023-03-06 22:20:47 +08:00
Aaron Ai c9975961f8 Remove uncompatible sed in runserver.sh 2023-03-06 16:08:47 +08:00
Lobo Xuandloboxu b9bbd52060 [ISSUE #6230] Optimizes ScheduleMessageService code and logic (#6231) 
Co-authored-by: loboxu <loboxu@tencent.com>
 2023-03-06 10:22:29 +08:00
Vincent Leeliwen.2022RongtongJin
 		cc8823cf62 [ISSUE #5883] DLedger commit log should override the getData (#5879) 
* fix: dledger commit log should override the getData

Change-Id: I665c5b9d7e96c5b7ccd035b32272be7223d7f454

* fix: adjust timer test case for dledger

* test: remove some test case to speed up unit test

Change-Id: I5aa348ab17977ce1f0e080f7801b28797ef82af9

* test: remove other timer dledger test

* Revert TimerMessageStoreTest

---------

Co-authored-by: liwen.2022 <liwen.2022@bytedance.com>
Co-authored-by: RongtongJin <jinrongtong16@mails.ucas.ac.cn>
 2023-03-06 09:20:41 +08:00
TheR1sing3un 18fcce664c [ISSUE #6250] Fix wrong value of MessageStoreConfig#storePathEpochFile 
1. fix wrong value of MessageStoreConfig#storePathEpochFile
 2023-03-05 21:57:24 +08:00
hardyfish ce99a7fe8a [ISSUE #6246] Optimize AcceptSocketService#run 2023-03-05 11:21:44 +08:00
mxsm 44a1694d1a [ISSUE #6244] Fix issue template feature request order incorrect (#6245) 2023-03-05 10:56:56 +08:00
rongtong d5d5a637f6 [ISSUE #6226] Shutdown flowMonitor when connection disconnect (#6227) 
* Shutdown flowMonitor when connection disconnect

* Whether the master is existed has more accurate judgment

* Shutdown flowMonitor when HAClient service end

* Pass the check style

* Modify according to comments
 2023-03-03 22:28:15 +08:00
mxsm 543c118200 [ISSUE #6060] Optimize AutoSwitchRoleBase#nextPort method (#6068) 
* [ISSUE #6060]Optimize AutoSwitchRoleBase#nextPort method

* polish code

* polish code style
 2023-03-02 20:01:02 +08:00
shenlin 19ad6f4392 doc:add rocketmq-eventbridge to README.md (#6221) 2023-03-02 08:17:18 +08:00
rongtong 88000dac21 [ISSUE #6196] Update lastConsumeTimestamp and lastPullTimestamp in DefaultLitePullConsumer (#6197) 
* Update lastConsumeTimestamp and lastPullTimestamp in DefaultLitePullConsumer

* Add lastConsumeTimestamp and lastPullTimestamp in consumerRunningInfo for DefaultLitePullConsumer

* Pass the check style
 2023-02-28 13:58:21 +08:00
hardyfish 33371e5d8e [ISSUE #6145] Modify Collections.sort usage (#6146) 
* modify Collections.sort usage

* modify Collections.sort usage
 2023-02-28 13:56:03 +08:00
hardyfish 086f9d130b remove invalid null check code (#6183) 2023-02-28 11:16:00 +08:00
Oliver f712bc873e [ISSUE #6185]Fix It does not take effect when acl is enabled in the proxy 2023-02-28 10:03:42 +08:00
hardyfish 84ed06158a [ISSUE #6131] Simplified ConsumeReviveObj code (#6132) 
* simplified ConsumeReviveObj code

* remove useless import
 2023-02-28 08:17:16 +08:00
hardyfish 8667a0d335 [ISSUE #6119] replace ScheduleMessageService method reference 2023-02-28 08:15:44 +08:00
rongtong 7a454477c5 [ISSUE #6194] The config enableControllerMode and enableDLegerCommitLog cannot both be true (#6195) 2023-02-27 16:35:31 +08:00
Lobo Xuandloboxu ed849142f5 proxy some optimization (#6175) 
Co-authored-by: loboxu <loboxu@tencent.com>
 2023-02-27 13:59:29 +08:00
lk 90bf886340 [ISSUE #6192] Set a default value when UniqID is empty in Proxy (#6193) 2023-02-27 12:56:26 +08:00
loboxu 2f93cbe051 Optimize getQueueIdByBroker naming ambiguity 2023-02-27 12:47:03 +08:00
loboxu 473e23b1dd Optimize command line tools QueryMsgByKey& QueryMsgTraceById 2023-02-27 12:46:48 +08:00
loboxu 72f458bccd Optimize command line tools QueryMsgByKey& QueryMsgTraceById 2023-02-27 12:46:48 +08:00
loboxu 254deb079a Command line tool QueryMsgByKey& QueryMsgTraceById：time range and number of data bars can be specified 2023-02-27 12:46:48 +08:00
loboxu 3bdab84c58 Optimize the timer implementation in Remoting 2023-02-27 12:46:22 +08:00
loboxu aeebe5e97b Optimize the timer implementation in Remoting 2023-02-27 12:46:22 +08:00
loboxu f1adb115c3 Optimize the timer implementation in Remoting 2023-02-27 12:46:22 +08:00
loboxu e3a591b483 raplace HashedWheelTimer 2023-02-27 12:46:22 +08:00
mxsm d6310dfdad [ISSUE #6117] Optimize NettyRemotingServer EventLoopGroup create (#6118) 2023-02-27 11:41:29 +08:00
TheR1sing3un 487473eb74 [ISSUE #6121] Optimize some code style in store module (#6122) 
* style(store): optimize some typos in store module

1. optimize some typos in store module

* style(store): rename DefaultHAClient#REPORT_HEADER to DefaultHAClient#REPORT_HEADER_SIZE

1. rename DefaultHAClient#REPORT_HEADER to
DefaultHAClient#REPORT_HEADER_SIZE

* style(store): optimize comment about DefaultHAClient#REPORT_HEADER_SIZE and DefaultHAConnection#TRANSFER_HEADER_SIZE

1. optimize comment about DefaultHAClient#REPORT_HEADER_SIZE and
DefaultHAConnection#TRANSFER_HEADER_SIZE
 2023-02-27 11:40:20 +08:00
rongtong e421c1a3ed [ISSUE #6180] Polish the issue_template (#6181) 2023-02-27 10:03:22 +08:00
rongtong 7cfffe7f48 [ISSUE #6163] Fix the issue of infinite retry of order message (#6164) 2023-02-23 18:59:56 +08:00
echooymxq 527350decf Polish the unified remoting logger name. 2023-02-23 15:10:35 +08:00
hardyfish bf11311135 [ISSUE #6057] Modify magic number code 2023-02-23 11:50:35 +08:00
wangtong.wt 0ec8c92a97 Match apache actions policy, use apache/rocketmq-test-tool in workflow 2023-02-23 09:49:50 +08:00
hardyfish 2e69a05fa5 [ISSUE #6159] fix typos 2023-02-23 09:45:33 +08:00
rongtong 2dff070a77 [ISSUE #6138] Add back the protection of the master branch (#6143) 2023-02-22 10:52:53 +08:00
hardyfish e3d173bbc5 [ISSUE #6087] fix typos (#6091) 2023-02-21 22:17:16 +08:00
yuz10 eda205b46f [ISSUE #6141] validate group when auto create subscription group (#6142) 
* validate group when auto create subscription group

* fix
 2023-02-21 22:12:21 +08:00
lk 6f115385bb [ISSUE #6149] remove handle when exceed renewMaxTimeMillis (#6150) 2023-02-21 19:00:33 +08:00
deepsolayueya月伢
 		68ec1afb2e [ISSUE #6140]Use apache/rocketmq-ci docker repo in CI (#6135) 
* Create pr-ci.yml

* Create pr-e2e-test.yml

* Create push-ci.yml

* Update push-ci.yml

* Update push-ci.yml

* Update pr-ci.yml

* Update README.md

* improve performance

* Update README.md

* Update push-ci.yml

* Create README.md

* modify docker repo

* Update push-ci.yml

* Update pr-e2e-test.yml

* use apache/rocketmq-ci docker repo

* Revert "Create README.md"

This reverts commit be678f1a65.

---------

Co-authored-by: yueya <102146039+cryptoya@users.noreply.github.com>
Co-authored-by: 月伢 <yuanchen.zyc@alibaba-inc.com>
 2023-02-21 15:51:48 +08:00