Commit Graph

1845 Commits

Author SHA1 Message Date
ZhangJian He 1b420cedfd Updated Notice file to 2022 (#3735) 2022-01-11 09:36:03 +08:00
von gosling e24794da71 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
2021-12-10 17:30:37 +08:00
tigerlee 21faa68b4c [maven-release-plugin] prepare for next development iteration 2021-10-22 13:44:14 +08:00
tigerlee c840b20833 [maven-release-plugin] prepare release rocketmq-all-4.9.2 rocketmq-all-4.9.2 2021-10-22 13:43:57 +08:00
tigerlee 143ac3185b prepare to release rocketmq 4.9.2 version 2021-10-20 00:34:12 +08:00
Git_Yang a2c6d33a2b [ISSUE #3415] Fix the problem of failure during checkstyle execution
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
2021-10-15 14:30:40 +08:00
panzhi cd45023d61 [ISSUE #3148]Support metadata export (#3149) 2021-10-13 19:47:51 +08:00
Duan 23506fd46a fix wrong comment (#3400) 2021-10-09 17:40:38 +08:00
tiger lee 7755aaa2bf Merge pull request #3039 from Aaron-He/dev20210623
[ISSUE #2962] Implement DefaultMQAdminExt::examineTopicConfig function
2021-10-07 18:30:58 +08:00
tgen 94a527c339 [ISSUE #3288] Fix producer always timeouts while sending first message (#3383) 2021-09-28 15:39:35 +08:00
Git_Yang c6a4b822ef [ISSUE #3384] Add SendBack message to SCHEDULE_TOPIC_XXXX stats #3385
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
2021-09-27 14:02:21 +08:00
孙不服 daf1b9df79 [ISSUE #503] NOT_CONSUME_YET not righht in RocketMQ Console (#3091) 2021-09-27 09:07:59 +08:00
Git_Yang b30bd87054 [ISSUE #2667] Repair 'file doesn't exist on this path'
Signed-off-by: zhangyang <Git_Yang@163.com>
2021-09-27 08:50:30 +08:00
WJL3333 d429aa24d3 [ISSUE #3375] Lazy init GetMessageResult only when find message 2021-09-26 18:47:27 +08:00
yuz10 6d78d7954c fix apache rat failure because of test result files 2021-09-26 15:49:34 +08:00
Git_Yang a83cdc5fa3 [format] Fix formatting errors (#3380)
Signed-off-by: zhangyang <Git_Yang@163.com>
2021-09-26 15:47:50 +08:00
tiger lee 4dbdbf0a25 Merge pull request #3357 from Jason918/RIP-7
RIP-7 Multiple Directories Storage Support
2021-09-25 22:47:22 +08:00
rongtong 538b6b7ffd [ISSUE #1869] Delay message can't be consumed when delay offset in delayOffset.json is wrong (#3358)
* fix(store):delay message can't be consumed when delay offset is wrong

* fix(store):delay message can't be consumed when delay offset is wrong

* fix(common):pass the code style

* fix(store): fix bug of get cq max offset

* fix(store): polish the code

* fix(store): fix bug to pass the UT test

* chore(store): polish log format

* chore(store): polish code style
2021-09-24 17:55:02 +08:00
Silverados fa935e832a fix document mistake (#3304)
message.getBody() return byte[], so change to length.
2021-09-24 17:39:54 +08:00
Silverados 9013cc5f64 fix document mistake (#3303)
fix message.getBody().length() -->  message.getBody().length
2021-09-24 17:39:17 +08:00
tiger lee 1e8e728259 Merge pull request #3295 from lwclover/develop
[ISSUE #3308] production level pull api demo
2021-09-24 00:46:35 +08:00
Jiang Haiting 14d50f9808 fix a typo 2021-09-23 13:56:28 +08:00
yuz10 67f43579cf add checkstyle to travis ci 2021-09-23 09:56:15 +08:00
tiger lee 0748aa0a5f Merge pull request #3322 from 844392610/develop_xm
[ISSUE #3347] Improve performance of expandIP, and readable
2021-09-23 01:35:12 +08:00
Jiang Haiting 7d4e5cd659 fix compile error 2021-09-22 19:48:27 +08:00
Jiang Haiting 474c4eb147 Fix bug for multi path file loading. Opt code checking for multi-path commitlog path in storePathCommitLog. 2021-09-22 19:46:12 +08:00
Jiang Haiting f32406d68a change default value of org.apache.rocketmq.store.config.MessageStoreConfig#MULTI_PATH_SPLITTER to ',' and can be changed by System.getProperty("rocketmq.broker.multiPathSplitter") 2021-09-21 18:17:15 +08:00
Jiang Haiting 255a202817 add path empty check to avoid error log in org.apache.rocketmq.store.DefaultMessageStore#getRuntimeInfo 2021-09-18 16:45:28 +08:00
tiger lee ee55441cbc Merge pull request #3335 from zhouwentong1993/patch-1
[ISSUE #XXXX] Update rocketmq client maven version
2021-09-18 01:16:09 +08:00
tiger lee a9837d9c3c Merge pull request #2965 from zhangjidi2016/add_getConsumerConfig_command
[ISSUE #2964] Add a query consumer config command in mqadmin.
2021-09-18 01:04:42 +08:00
tiger lee 67ccb7f7be Merge pull request #2729 from wz2cool/master
[ISSUE #2726] retrying by customizing response code
2021-09-18 00:26:32 +08:00
zhangjidi2016 0de4038f82 [ISSUE #3361]DefaultMQProducer's constructor can call the overloaded constructor. (#3362)
Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
2021-09-17 19:45:45 +08:00
Jiang Haiting 466bb98eef fix error in org.apache.rocketmq.store.DefaultMessageStore.CleanCommitLogService#isSpaceFull 2021-09-17 11:16:28 +08:00
tiger lee a9ae546ba0 Merge pull request #2437 from maixiaohai/DLQ_perm
[ISSUE #2436] DLQ topic default perm change
2021-09-16 14:39:14 +08:00
zhangxu16 502ca6041e fix ci 2021-09-16 13:48:06 +08:00
Jiang Haiting 9b0e31e469 1. fix initial value of physicRatio in org.apache.rocketmq.broker.processor.SendMessageProcessor#diskUtil
2. use minPhysicsUsedRatio instead of max in org.apache.rocketmq.store.DefaultMessageStore#getRuntimeInfo
2021-09-16 11:04:25 +08:00
Jiang Haiting 8e19069c98 fix test error 2021-09-16 10:55:14 +08:00
Jiang Haiting a9a7dfa722 RIP-7 Multiple Directories Storage Suppor 2021-09-15 22:36:34 +08:00
huangli 311d76f9c8 [ISSUE 3194] [PART C] Replace AtomicLong with LongAdder in StatsItem.java to improve performance (#3351) 2021-09-14 23:48:15 +08:00
yuz10 147d23e3ed [ISSUE #3281 ][acl] fix fail to delete topic perm list and global white address(#3128) (#3280)
* fix fail to remove topic/group permissions and global white address of acl config

* update acl config for all brokers

* refactor rename UtilAll.string2List and list2String

* fix fail to remove whiteRemoteAddress of acl config
2021-09-14 15:33:38 +08:00
tiger lee f9a0f530e6 Merge pull request #1858 from coder-zzzz/github_features/#1848
[ISSUE #1848] Add write perm admin command
2021-09-13 14:11:20 +08:00
racoon bf343a31a9 [ISSUE #3225]change Random to ThreadLocalRandom in broker 2021-09-13 13:59:37 +08:00
WJL3333 83b04d03f6 [ISSUE #3346]Avoid double parse remoteAddr in rpcHook call 2021-09-13 13:55:35 +08:00
844392610 7314183836 netadress toUpperCase beforehand 2021-09-12 22:02:32 +08:00
aaron ai 53c55f7dc5 [ISSUE #3245] Use df algorithm to calculate the disk used ratio 2021-09-12 16:50:48 +08:00
lizhiboo 36041006aa [ISSUE #3314] Make mqClientApi request timeout settable 2021-09-12 16:24:37 +08:00
Git_Yang 564ee290c7 [ISSUE] Add get stats and single queue stats for schedule topic
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
2021-09-12 10:17:38 +08:00
张旭 8434658798 [ISSUE #2724] Resend message to DLQ directly when max reconsume times reach (#3318)
* [Store] Resend message directly to DLQ when max reconsume times reach

* set msg delaylevel=0 when topic is DLQ

Co-authored-by: zhangxu16 <zhangxu16@xiaomi.com>
2021-09-11 17:21:50 +08:00
yuz10 4b7a90a32b [#3326] fix send trace fail if useTLS=true (#3325) 2021-09-11 12:39:19 +08:00
truman.p.du b2aa85d33a [ISSUS #3340] (doc)add hyperlink for client repos in the introduction. (#3338)
Increase multilingual client repository link
2021-09-10 15:37:10 +08:00