Commit Graph
2058 Commits
Author SHA1 Message Date
Echoandxiongyujie 6fca4e866c [ISSUE #4160]remove the final modifier of a method which is already in a final class (#4163)
Co-authored-by: xiongyujie <xiongyujie@highlight.mobi>
2022-04-20 10:54:35 +08:00
cnScarb 9f7142bdd1 [ISSUE #4175] Prevent update topic on slave (#4176)
* Prevent update topic on slave

* Prevent update subscription group on slave
2022-04-19 10:24:04 +08:00
李晓双 Li Xiao Shuang 50e314eb8a [ISSUE #4123] Explicit type argument can be replaced with <> for RouteInfoManager (#4124)
* Explicit type argument can be replaced with <> for RouteInfoManager

* Explicit type argument can be replaced with <> for RouteInfoManager
2022-04-17 23:58:38 +08:00
灼华and灼华 84f03c34b5 [ISSUE #4143] Remove file lock related code snippets in index file (#4135)
* Remove fileLock related code snippets in IndexFile

* Remove unused fileChannel

Co-authored-by: 灼华 <geyu@didiglobal.com>
2022-04-17 23:54:30 +08:00
Kvicii 320b728d6d [ISSUE #4167] cleanup code (#4013) 2022-04-17 23:46:26 +08:00
6U-U9 d100d3c9a5 [ISSUE #4167] Replace Charset.forName("UTF-8") with StandardCharsets.UTF_8 (#4024)
* Replace Charset.forName("UTF-8") with StandardCharsets.UTF_8

* Remove the specification of Charset according to SimplePullConsumer
2022-04-17 23:02:07 +08:00
dugenkui aa908ce825 [ISSUE #4103] Simplify string-list-join in Message (#4104)
[ISSUE #4103] Simplify string-list-join in `Message`
2022-04-15 11:10:53 +08:00
灼华and灼华 f120645a11 [ISSUE #4167] Optimize the logic of MessageDecoder#decodeMessageId method (#4082)
Co-authored-by: 灼华 <geyu@didiglobal.com>
2022-04-14 23:06:09 +08:00
zhangyang 93edad2cb3 [ISSUE #4033] fix async deliver msg will resend forever when serivce not avliable (#4045)
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
2022-04-13 10:31:23 +08:00
gogodjzhuanddjzhu 2897bbfba2 [ISSUE #4150] Fix spelling mistakes on docs (#4141)
Co-authored-by: djzhu <zhudejun1@huya.com>
2022-04-13 09:16:29 +08:00
caigy 9563683c2d [ISSUE #4155] fix acl test 2022-04-13 09:14:28 +08:00
刘月财 ead6274b3e fix mac 12+ slow bug (#4010) 2022-04-11 09:29:30 +08:00
hnandhening 47561bdd85 [ISSUE #3666] fix npe (#4136)
Co-authored-by: hening <ninghe.hn@alibaba-inc.com>
2022-04-08 19:20:49 +08:00
dependabot[bot] 50f2b32451 Bump junit from 4.12 to 4.13.1 in /test (#4119)
Bumps [junit](https://github.com/junit-team/junit4) from 4.12 to 4.13.1.
- [Release notes](https://github.com/junit-team/junit4/releases)
- [Changelog](https://github.com/junit-team/junit4/blob/main/doc/ReleaseNotes4.12.md)
- [Commits](https://github.com/junit-team/junit4/compare/r4.12...r4.13.1)

---
updated-dependencies:
- dependency-name: junit:junit
  dependency-type: direct:development
...

Signed-off-by: dependabot[bot] <support@github.com>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2022-04-08 15:12:11 +08:00
drgnchan 8745d4c538 [ISSUE #4129] Fix typo in CommitLog.java 2022-04-07 10:52:20 +08:00
zhangjidi2016andzhangjidi 13765b040a [ISSUE #3940]Optimize AllocateMessageQueueStrategy (#3941)
* [ISSUE #3940]Optimize AllocateMessageQueueStrategy

* remove the check in AllocateMessageQueueByConfig

Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
2022-04-06 22:28:49 +08:00
9f82b1e6b6 [Doc] Fixed typo in getStartIndex method in RocketMQ_Example.md file (#4012)
* Update .travis.yml

Depracated MODERATE noisy mail for dev@rocketmq.apache.org. Still Failing: apache/rocketmq#5670 (5.0.0-alpha-static-topic - 5ebc327) @dongeforever

* Updated Notice file to 2022 (#3735)

* 4.2消息列表分割示例  getStartIndex方法中变量名称错误

方法getStartIndex() 中messages.get(curIndex)修正为messages.get(currIndex);

Co-authored-by: von gosling <vongosling@apache.org>
Co-authored-by: ZhangJian He <shoothzj@gmail.com>
Co-authored-by: tigerweili <tigerweili@tencent.com>
2022-04-06 22:17:54 +08:00
李晓双 Li Xiao Shuang c5db5ac3e4 [ISSUE #4125] Anonymous new Runnable() can be replaced with lambda (#4031) 2022-04-06 22:02:00 +08:00
rongtong e7c87fa1ce [ISSUE #4110] Update dledger version to 0.2.4 (#4111) 2022-04-06 09:16:45 +08:00
dugenkui fd554ab120 [Document] Update user_guide.md: Fix for link. (#4085)
* Update user_guide.md

Fix for link: md field regard 'full width text' as part of link.

Replace linkage with '#'.

* Highlight java code

* fix typo in TraceDispatcher
2022-04-02 10:00:57 +08:00
cnScarb e3b67484b0 [ISSUE #4048] Make storePathCommitLog base on storePathRootDir (#4057) 2022-04-01 09:25:50 +08:00
yuz10 336939080e [ISSUE #4035] rename some commands (#4036)
* rename some commands

* update doc
2022-04-01 08:58:27 +08:00
zhangyang21 4f7a224a04 [ISSUE #3699] fix unit test
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
2022-03-31 18:42:51 +08:00
4574d59f4b fix clusterRT and checkMsgSendRT (#4047)
* Update .travis.yml

Depracated MODERATE noisy mail for dev@rocketmq.apache.org. Still Failing: apache/rocketmq#5670 (5.0.0-alpha-static-topic - 5ebc327) @dongeforever

* Updated Notice file to 2022 (#3735)

* fix description mismatch of mqadmin command

Co-authored-by: von gosling <vongosling@apache.org>
Co-authored-by: ZhangJian He <shoothzj@gmail.com>
Co-authored-by: tigerweili <tigerweili@tencent.com>
Co-authored-by: shizhili <shizhili@cmss.chinamobile.com>
2022-03-30 14:22:37 +08:00
zhangyang21 45010d9bdf [ISSUE #4050] fix origin messsage id missing from dead leetter meessage
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
2022-03-30 10:45:30 +08:00
zhangyang 6817856d08 [ISSUE #4054] fix doc format (#4055)
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
2022-03-30 10:24:00 +08:00
李晓双 Li Xiao Shuang 9fff8ae01f [ISSUE #4053] NamesrvController code optimization 2022-03-29 19:38:10 +08:00
ScarbWin 18287f64cf [ISSUE #4048] Make storePathCommitLog base on storePathRootDir 2022-03-29 14:03:31 +08:00
李晓双 Li Xiao Shuang 818ef2152f RemotingCommandException is not thrown in a method (#4030) 2022-03-28 15:01:06 +08:00
hjl11 c121565c3e [ISSUE #4040] Unnecessary toString methods deleted (#4041) 2022-03-28 10:15:43 +08:00
ScarbWin 02228d870c Fix #4004 2022-03-25 09:35:56 +08:00
panzhiandpanzhi33 f7b4ce3a3f [ISSUE #4028] wrong log output (#4029)
* wrong log output

* wrong log output

Co-authored-by: panzhi33 <wb-pz502261@alibaba-inc.com>
2022-03-25 09:30:01 +08:00
hnandhening 1a72ffd200 fix docs error (#4023)
Co-authored-by: hening <ninghe.hn@alibaba-inc.com>
2022-03-24 10:13:12 +08:00
彭小漪 0870a83306 [ISSUE #3924] It may be better to change the method StoreStatsService#initPutMessageDistributeTime() to private. (#3925)
* Rename method initPutMessageDistributeTime to resetPutMessageDistributeTime.
2022-03-23 11:24:17 +08:00
zhangjidi2016andzhangjidi f57ea77dbb [ISSUE #4002]Optimize some mqadmin command execution results output (#4003)
Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
2022-03-22 10:49:20 +08:00
humkumandhankunming e283dccd06 add shutdown script for batchproducer.sh (#4015)
Co-authored-by: hankunming <hankunming@xiaomi.com>
2022-03-22 09:39:36 +08:00
zhangjidi2016andzhangjidi 6ff00ed053 [ISSUE #4000]Fix the warn log input in command tools (#4001)
Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
2022-03-19 17:56:56 +08:00
sunxi92 c1aeca291e [#3942]If both acl and message trace are enabled and the default topic RMQ_SYS_TRACE_TOPIC is used for message trace, you don't need to add the PUB permission of RMQ_SYS_TRACE_TOPIC topic to the acl config. (#3943)
* If both acl and message trace are enabled and the default topic RMQ_SYS_TRACE_TOPIC is used for message trace, you don't need to add the PUB permission of RMQ_SYS_TRACE_TOPIC topic to the acl config.

* Delete Chinese character in comments.
2022-03-15 20:11:51 +08:00
彭小漪 03c5a3d171 [ISSUE #3985] Remove shuffle operation before sorting the list of 'FaultItem'. (#3986) 2022-03-14 20:48:23 +08:00
彭小漪 2b51321179 [ISSUE#3983] Optimize warn log output when sending exceptions are encountered. (#3984) 2022-03-14 20:47:36 +08:00
wangfan adbf3db717 [ISSUE #3955] delete useless check 2022-03-14 20:17:42 +08:00
WJL3333 3378da69ed [ISSUE #3882]Nameserver change modify topicQueueTable in RouteInfoManager (#3881)
* 1. nameserver change. modify `topicQueueTable` in `RouteInfoManager`
add brokerName to QueueData mapping to speed up brokerName related logic

* fix checkstyle

* fix unit test

* refactor route info manager unit test

* 1. when `pickupTopicRouteData` only add filter server address if filter server table not empty.

2. merge with patch #3893

* 1. `RouteInfoManger` only add filter server list when filterServerTable contains brokerAddr

* 1. add master change info log

* 1. add master change info log

* 1. add delete topic test
2. add slave change to master test
2022-03-14 20:15:43 +08:00
rongtong 8cd998829a Fix using wrong offset when deliver in ScheduleService (#3967) 2022-03-14 19:29:15 +08:00
在红尘中成仙 895bd95e82 fix a flaky test (#3959) 2022-03-14 14:21:16 +08:00
彭小漪 95202f1e6f docs: Add the link to Apache RocketMQ MQTT in the readme.md (#3971) 2022-03-13 17:13:42 +08:00
tianliuliu 40d9505786 [ISSUE #3957] Fix LmqConsumerOffsetManager deserialize error (#3958)
LmqConsumerOffsetManager deserialize error (#3958)
2022-03-11 15:29:53 +08:00
李晓双 Li Xiao Shuang c43620f26f [ISSUE #3950] Anonymous new Callable() replaced with lambda (#3951)
* Anonymous new Callable()  replaced with lambda

* add unit test
2022-03-11 10:10:20 +08:00
446b76b07b typo: best_practice.md (#3939)
* Update .travis.yml

Depracated MODERATE noisy mail for dev@rocketmq.apache.org. Still Failing: apache/rocketmq#5670 (5.0.0-alpha-static-topic - 5ebc327) @dongeforever

* Updated Notice file to 2022 (#3735)

* Update best_practice.md

fix word

Co-authored-by: von gosling <vongosling@apache.org>
Co-authored-by: ZhangJian He <shoothzj@gmail.com>
Co-authored-by: tigerweili <tigerweili@tencent.com>
2022-03-08 16:30:26 +08:00
ymingxuandyangmingxu febc083605 [ISSUE #3561] Optimize consuming messages with namespace example
Co-authored-by: yangmingxu <mingxu914>
2022-03-08 16:26:33 +08:00
caigy 7a5d937c76 [Issue #3922] Fix bugs in ACL modification (#3927)
* fix NPE when updating account auth if no accounts defined in acl config file

* fix: creating globalWhiteRemoteAddresses failed when default acl config file did not exist

* move plain_acl.yml out of conf/acl/: conf/plain_acl.yml is the default acl config file and config of different accounts can be placed under conf/acl/

* fix merge problem

* fix: 1. errors when processing empty config files;  2.accounts can't be added back after deleting account part in ACL config files

* fix merge problem

* fix test bug

* add test

* add missing test config files
2022-03-07 17:11:09 +08:00