opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 02:23:24 +08:00
Code Issues Packages Projects Releases Wiki Activity
8,039 Commits 73 Branches 40 Tags
465bfcf802fe8103b05aef50cb23224ecde238b7
Commit Graph
628 Commits
Author SHA1 Message Date
hiyoandLi Zhanhui 0faa0a2c7d [ISSUE #6414] polish MQClientAPIImpl.getDefaultTopicRouteInfoFromName… (#6452) 
* [ISSUE #6414] polish MQClientAPIImpl.getDefaultTopicRouteInfoFromNameServer parameters

* Fix to make Bazel CI pass

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

* Fix typo

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>

---------

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
 2023-03-23 20:30:21 +08:00
Cyandcyu fe0a0a0789 [ISSUE #6440] Optimize the code of consumer thread name,and support tag the name of scheduledExecutor thread. (#6441) 
Co-authored-by: cyu <dingchengyu@hydee.cn>
 2023-03-23 14:16:24 +08:00
mxsm 68362151a2 [ISSUE #6396] Fix DefaultMQPushConsumer javadoc typo (#6397) 2023-03-20 10:59:15 +08:00
yuz10 3613821c6a [ISSUE #6365] fix no log in benchmark (#6366) 
* fix no log in benchmark

* remove logging debug
 2023-03-18 19:52:05 +08:00
hardyfish 94db42ade7 [ISSUE #6292] fix typos (#6293) 
* fix typos

* fix typos

* fix typos
 2023-03-15 15:41:01 +08:00
TheR1sing3un c94c65b691 fix(admin): fix incompatible command: CleanBrokerMeta 
1. fix incompatible command: CleanBrokerMeta
 2023-03-14 09:40:15 +08:00
TheR1sing3un f843851788 fix(controller): fix some bug to pass AutoSwitchRoleIntegrationTest 
1. fix some bug to pass AutoSwitchRoleIntegrationTest
 2023-03-14 09:40:15 +08:00
TheR1sing3un cfdfa0ea51 feat(broker): implement the general register to controller protocol 
1. implement the general register to controller protocol
 2023-03-14 09:40:15 +08:00
TheR1sing3un 9577aacbc0 feat(controller): add protocols about new register flow 
1. add protocols about new register flow
 2023-03-14 09:40:15 +08:00
TheR1sing3un a1de567e11 [ISSUE#5045] Refactor the register and elect-master process in controller mode (#5046) 
* refactor(controller): refactor the register logic

1. refactor the register logic

* refactor(controller): remove unused field in ElectMasterEvent

1. remove unused field in ElectMasterEvent

* feat(controller): add a tryElectMaster request and process logic about it

1. add a tryElectMaster request and process logic about it

* feat(controller): refactor ReplicasInfoManagerTest

1. refactor ReplicasInfoManagerTest

* refactor(controller): refactor DLedgerControllerTest

1. refactor DLedgerControllerTest

* refactor(controller): refactor ControllerManagerTest

1. refactor ControllerManagerTest

* refactor(controller): refactor ReplicasInfoManagerTest

1. refactor ReplicasInfoManagerTest

* refactor(controller): refactor register process and pass the junit test

1. refactor ReplicasInfoManagerTest

* style(broker): rename a constant

1. rename a constant

* feat(controller): update the DLedger dependency from v0.27 to v0.30

1. update the DLedger dependency from v0.27 to v0.30

* style(controller): add a white-line just for trigger GitHub action again

1. add a white-line just for trigger GitHub action again

* feat(controller): combine electMaster api and brokerTryElectMaster api

1. combine electMaster api and brokerTryElectMaster api

* feat(controller): add a logic about verifying the broker id returned from registering

1. add a logic about verifying the broker id returned from registering

* fix(controller): remove unused code and add a warning log in ControllerManager

1. remove unused code and add a warning log in ControllerManager

* fix: resolve conflicts

1. resolve conflicts

* fix(controller): remove unused class

1. remove unused class

* fix(controller): Resolve conflicts after merging

1. Resolve conflicts after merging

* refactor(controller): Refactor ReplicasInfoManager#elect

1. Refactor ReplicasInfoManager#elect

* style(controller): remove unused imports

1. remove unused imports

* style(controller): remove unused imports

1. remove unused imports

* fix(controller): resolve conflicts after merging develop branch

1. resolve conflicts after merging develop branch

* rerun

* fix(controller): resolve conflicts in ReplicasInfoManagerTest#testRegisterNewBroker after merging develop branch

1. resolve conflicts in ReplicasInfoManagerTest#testRegisterNewBroker after merging develop branch

* style(controller): pass style check

1. pass style check
 2023-03-14 09:40:15 +08:00
mxsm 37ff93a27b [ISSUE #6331] Optimlize DefaultMQPushConsumerImpl#subscribe method (#6332) 2023-03-14 08:12:53 +08:00
mxsm 47355d115d [ISSUE #6272]Add judgment for SendLatencyFault in MQFaultStrategy#selectOneMessageQueue (#6273) 
* [ISSUE #6272]Add judgment for SendLatencyFault in MQFaultStrategy#selectOneMessageQueue

* fix code style
 2023-03-13 14:19:08 +08:00
mxsm 3c770c95ce [ISSUE #6302] Fix DefaultMQPushConsumerImpl code style (#6303) 2023-03-11 16:25:14 +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 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 086f9d130b remove invalid null check code (#6183) 2023-02-28 11:16:00 +08:00
loboxu 2f93cbe051 Optimize getQueueIdByBroker naming ambiguity 2023-02-27 12:47:03 +08:00
rongtong 7cfffe7f48 [ISSUE #6163] Fix the issue of infinite retry of order message (#6164) 2023-02-23 18:59:56 +08:00
Aaron Ai 975b4f1f82 [ISSUE #6103] Add AsyncAppender support for client logging 2023-02-18 01:07:22 +08:00
zhouxiang 0f878b5157 [maven-release-plugin] prepare for next development iteration 2023-02-16 12:35:58 +08:00
zhouxiang b8e9334d2a [maven-release-plugin] prepare release rocketmq-all-5.1.0 2023-02-16 12:35:58 +08:00
zhouxiang 83d6778747 [ISSUE #6030] Update version to 5.1.0-SNAPSHOT 2023-02-16 12:35:58 +08:00
hardyfish 99c980ea37 [ISSUE #6082] Simplify MQClientAPIImpl processSendResponse code 2023-02-16 08:40:01 +08:00
hardyfish 1ae3aee211 [ISSUE #6077] fix issues that messageStore could be null 2023-02-16 08:39:04 +08:00
hardyfish 2e8ef04646 [ISSUE #6043] Optimize the DefaultLitePullConsumerImpl isSetEqual method code (#6044) 
* optimize the DefaultLitePullConsumerImpl isSetEqual method code

* optimize the DefaultLitePullConsumerImpl isSetEqual method code
 2023-02-13 13:38:30 +08:00
hardyfish bc1c5e1b74 [ISSUE #6033] modify TraceContext toString method (#6034) 
* modify TraceContext toString method

* modify TraceContext toString method

* code optimization

* format code
 2023-02-12 15:27:58 +08:00
CoderBruis d3ebe02ccb [ISSUE #6007] Remove useless if judgement 
Remove useless if judgement
 2023-02-11 13:03:42 +08:00
rongtong a1d1cf8b30 [ISSUE #5983] Make consumer support flow control code better (#5984) 
* When encountering the flow control code, pull it after 20ms instead of 3s

* When encountering the flow control code, pull it after 20ms instead of 3s
 2023-02-06 13:41:31 +08:00
mxsm ce2ecc30d4 [ISSUE #5939]Adjust the MQClientInstance#sendHeartbeatToAllBroker catch code block log print level from info to warn (#5940) 2023-02-05 16:52:16 +08:00
loboxu 4e6740949d Remove the useless exception class: MQRedirectException #5963 2023-02-03 13:23:41 +08:00
rongtong 0ea930182c GetSyncStateSetSubCommand can also print that the broker is not in syncStateSet (#5935) 2023-01-28 10:08:51 +08:00
SSpirits 46869c9e9b [ISSUE #5876] fix resource leak in DefaultLitePullConsumerTest 2023-01-27 17:13:02 +08:00
mxsm c82ab449a4 [ISSUE #5859]Optimize String#format in DefaultMQProducerImpl (#5870) 
* [ISSUE #5859]Optimize String#format in DefaultMQProducerImpl

* polish code
 2023-01-17 16:47:17 +08:00
xiaoyifang f20ce8a563 [ISSUE #5766] Fix possible message NPE (#5769) 2023-01-04 21:50:59 +08:00
lybuestc 3effd04fbb [ISSUE #5763] add the default subscribe * tag method (#5764) 2022-12-29 14:24:07 +08:00
rongtong d5e6fb6634 Fix bug that make static topic ITs unable to pass (#5645) 2022-12-07 14:58:30 +08:00
lizhimins 49fc6eded9 [ISSUE #5568] Support long length group and topic for pop mode consumption (#5611) 
* [ISSUE #5568] Support long length group and topic for pop mode consumption
Co-authored-by: 斜阳 <terrance.lzm@alibaba-inc.com>
 2022-12-07 10:26:50 +08:00
mxsm 0ac09dee70 [ISSUE #5647]Polish PullMessageService some methods parameter name (#5650) 2022-12-06 08:43:20 +08:00
rongtong e5fadc7db7 Deprecated the ambiguous methods of lite pull consumer (#5640) 2022-12-04 12:19:28 +08:00
rongtongandSSpirits 80b63ab1d7 Persist consumer offset should not be disabled when auto commit is turned off (#5635) 
Co-authored-by: SSpirits <admin@lv5.moe>
 2022-12-02 16:27:05 +08:00
Aaron Ai 4469fb51dd Update group id of rocketmq logging (#5564) 2022-11-22 11:31:21 +08:00
Aaron Ai a68078fef8 [ISSUE #5484] Replace logging module with the shaded logback (#5540) 
* Replace logging module with the shaded logback

* Add license header

* Fix bazel compile issue
 2022-11-21 16:30:15 +08:00
rongtong d781271654 Move the header of the controller to the upper layer (#5550) 2022-11-20 21:51:32 +08:00
yukon 506b563f55 Revert "[ISSUE #5484] Replace Logging Module with Shaded Logback (#5524)" (#5537) 
This reverts commit 809ff6b3e0.
 2022-11-17 20:04:17 +08:00
Aaron AiandLi Zhanhui 809ff6b3e0 [ISSUE #5484] Replace Logging Module with Shaded Logback (#5524) 
* Remove ClientLogger

* WIP

* WIP

* Rename logger to log

* Make it compile

* WIP

* Fix bazel to use shaded slf4j

* Fix DeleteExpiredCommitLogSubCommandTest

* Fix pom.xml duplication

* Fix maven deps

* Add test logback configuration file

* Fix unit test output

* Fix logback configuration file

* All logging are made on top of slf4j

* Fix test log configuration file name

* Fix test log configuration file name for test module

* All logging are shaded slf4j targeted

* DLedger has an explicit dependency on slf4j

* Fix DLedger

* Fix DLeader issue

* Move logback configuration files to each module

Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
 2022-11-17 00:38:28 +08:00
SSpiritsandLi Zhanhui ec5d3236f6 invert dependency between remoting and common module (#5503) 
* invert dependency between remoting and common module

* fix bazel

* Fix Bazel warning of indirect dependency

* remove duplicate class ServiceThread

* fix conflict

* revert delete class ServiceThread because of introduced by dledger

Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
 2022-11-11 13:34:31 +08:00
Aaron Ai 630abced4e Remove unnecessary retries in sendMessageBack (#5501) 2022-11-10 19:36:54 +08:00
Aaron AiandLi Zhanhui c217d8bb80 [ISSUE #5481] Decrease the repeated consumption probability of expired message (#5483) 
* Decrease the repeated consumption probability of expired message

* Polish code

* Make test method name consistent with that of main source file

Co-authored-by: Li Zhanhui <lizhanhui@gmail.com>
 2022-11-09 20:02:20 +08:00
gongzhongqiangandgongzhongqiang 4b3eafe260 Fix error core-concept url. (#5253) 
Co-authored-by: gongzhongqiang <gongzhongqiang@gigacloudtech.com>
 2022-11-09 19:33:10 +08:00
jasonjavaYY 0d44ea183e modify variable name whichItemWorst to randomItem to resolve ambiguity (#5436) 2022-11-07 15:22:31 +08:00