opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-10-29 17:25:35 +08:00
Code Issues Packages Projects Releases Wiki Activity
1,848 Commits 75 Branches 40 Tags
2385f0446832d4e799c16d280a88cafc548fab39
Commit Graph
267 Commits
Author SHA1 Message Date
shendongsd 2385f04468 [ISSUE #3381] Fix bug of when role change but not register again (#3442) 2021-11-03 14:12:29 +08:00
alitor 6b8a2b2fce trivial cleanups (#3403) 2021-10-26 13:44:23 +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 2021-10-22 13:43:57 +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
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
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
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
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
racoon bf343a31a9 [ISSUE #3225]change Random to ThreadLocalRandom in broker 2021-09-13 13:59: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
张旭andzhangxu16 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
zongtanghu a7e71cb4ca [maven-release-plugin] prepare for next development iteration 2021-08-16 21:21:07 +08:00
zongtanghu a1bfe1afce [maven-release-plugin] prepare release rocketmq-all-4.9.1 2021-08-16 21:20:36 +08:00
zongtanghu 73db2970ff [#Issue3205]Fix the issue of code style in client and broker modules. 2021-08-01 18:22:54 +08:00
Heng Du 3e01424138 Merge pull request #3134 from areyouok/dev_speed_G 
[ISSUE 2883] [Part G] Optimise parse performance for SendMessageRequestHeaderV2
 2021-07-31 00:31:22 +08:00
Heng Du 2509b0edc5 Merge pull request #2961 from areyouok/dev_speed_F 
[ISSUE #2883] [Part F] Improve produce performance in M/S mode.
 2021-07-31 00:30:57 +08:00
makabakaboom d067bfc214 [ISSUE #3192] Make free disk value more accurate 
make free disk value more accurate
 2021-07-30 21:56:32 +08:00
huangli a137e48a67 [ISSUE 2883] [Part G] Optimise parse performance for SendMessageRequestHeaderV2, unit test 2021-07-30 15:50:07 +08:00
gorden5566 1b757b4022 [ISSUE #3196] Check if "requestHeader" is null before "requestHeader.getTopic()" 2021-07-30 15:00:48 +08:00
Heng Du 9a9039e8dc Merge pull request #3032 from messense/upgrade-netty-all 
[ISSUE #3031] Upgrade netty-all dependency version to 4.1.65.Final
 2021-07-23 13:32:41 +08:00
Heng Du c63ec20dee Merge pull request #2058 from RealBar/fix/issue2055 
[ISSUE #2055] Fix NPE in SendMessageProcessor.handleRetryAndDLQ
 2021-07-21 16:47:36 +08:00
Heng Du 74aa3e0056 Update SendMessageProcessor.java 2021-07-21 15:55:33 +08:00
zhangxu16 b822db062b Fix DLQ can't be query sometimes 2021-07-14 00:35:46 +08:00
huangli b13a4c862f [ISSUE 2883] [Part G] Optimise parse performance for SendMessageRequestHeaderV2 2021-07-07 22:28:29 +08:00
huangli 3183122c01 Eliminate array copy (#2886) 
[Part C] Improve produce performance in M/S mode.
 2021-07-06 21:47:12 +08:00
lizhiboo 9a5ec9082f [ISSUE #3109]Return a no-support value when not match any request code 2021-07-01 15:00:27 +08:00
messense 361eb8d286 Upgrade netty-all dependency version to 4.1.65.Final 2021-06-23 13:36:34 +08:00
zongtanghu df1d93fc88 [maven-release-plugin] prepare for next development iteration 2021-06-10 21:36:05 +08:00
zongtanghu 5203d52f1b [maven-release-plugin] prepare release rocketmq-all-4.9.0 2021-06-10 21:35:41 +08:00
huangli 20b6cddb94 [ISSUE 2883] Remove an duplicate MessageDecoder.string2messageProperties for each message, and prevent store "WAIT=true" property (in most case) to save 9 bytes for each message. 2021-06-01 22:49:56 +08:00
Lunaticfandcenter-liu f37dc187f2 Fix some code style issue and remove redundant code (#1378) 
Co-authored-by: center-liu <liu.chaofan@foxmail.com>
 2021-05-19 19:43:42 +08:00
张旭andzhangxu16 f5cf3ccebd Fix ORIGIN_MESSAGE_ID field not write into commitlog (#2869) 
Co-authored-by: zhangxu16 <zhangxu16@xiaomi.com>
 2021-05-19 12:28:33 +08:00
huangli 541c35d054 Change log level to debug: "Half offset {} has been committed/rolled back" 2021-05-12 22:25:38 +08:00
drgnchan af8a9648c7 [ISSUE #2729] Replace with Math.min method call 2021-04-12 10:05:16 +08:00
panzhi 4645942680 [ISSUE #2748] Fix deleteSubscriptionGroup not remove consumer offset 2021-03-24 11:39:12 +08:00
panzhi 97c77701f8 [ISSUE #2677] Update varible name 2021-02-19 14:59:20 +08:00
赵延 e297221d50 [ISSUE #2622] Change variable name 'lockTreeMap' to 'treeMapLock' (#2624) 2021-02-01 17:32:02 +08:00
RongtongJin f35cafe128 [maven-release-plugin] prepare for next development iteration 2020-12-08 18:17:12 +08:00
RongtongJin 39bb9386f1 [maven-release-plugin] prepare release rocketmq-all-4.8.0 2020-12-08 18:16:49 +08:00
zhangxu16 0a16ff6a5f DLQ topic default perm change 2020-11-18 20:39:59 +08:00
rongtong c932941f30 [ISSUE #2334] Polish the log and response remark when service not available (#2335) 
* enhancement(response & log):polish the log and response remark when service not available

* enhancement(response remark & log): make log and response remark better understand

* chore(style): modify code style to pass CI tests
 2020-10-12 08:58:21 +08:00
JasonWong 77d24def3a [ISSUE# 2325] Use CopyOnWriteArrayList to avoid possible thread safety issues 2020-10-07 14:12:29 +08:00
李强 f07bc79daa [ISSUE #2283] Fix the spelling mistake in ProducerManager & some code optimization 
(cherry picked from commit 798d9803b9e831b19957cbdb74571e4c6c341ce3)
 2020-09-03 23:08:36 +08:00
affe 9d34fadce6 Merge pull request #2236 from Demogorgon314/develop 
[ISSUE #2233] Enhancement MQBrokerException include broker information…
 2020-08-19 14:53:46 +08:00
androidkaifa1 bbfdd929f5 [ISSUE #2170] Update BrokerOuterAPI (#2203) 
* READM.md: update BrokerOuterAPI

* fix tab error

* use thread-safe list

* use thread-safe list
 2020-08-11 10:29:09 +08:00