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
2,378 Commits 73 Branches 40 Tags
3bbca727aec8d59e34b6830a7be9bba9ed6b6b2e
Commit Graph
347 Commits
Author SHA1 Message Date
kaiyi.lk 4882427b4c [ISSUE #3949] for check style and test case 2022-07-13 11:29:31 +08:00
kaiyi.lk 67d749b569 [ISSUE #3949] v2 support 2022-07-13 11:29:29 +08:00
zhouxiang 30aa97317b [ISSUE #3949] Pass checkstyle 2022-07-13 11:29:27 +08:00
zhouxiang 6739a05101 [ISSUE #3949] Fix pop ResponseCode.POLLING_TIMEOUT 2022-07-13 11:29:24 +08:00
kaiyi.lk 6b877b5bdd [ISSUE #3949] v2 test cases 2022-07-13 11:29:20 +08:00
kaiyi.lk 35f06a4fd2 [ISSUE #3949] v2 client manager 2022-07-13 11:29:18 +08:00
zhouxiang c7b81c13c9 [ISSUE #3949] Add integration test 
* Write response when POLLING_TIMEOUT
* Fix Channel isWritable
* Use TransactionId in GrpcClientChannel and SendMessageResponseHandler
* Optimize sendMessage and nackMessage
 2022-07-13 11:29:18 +08:00
kaiyi.lk 41a976693c [ISSUE #3949] v2 test cases 2022-07-13 11:29:18 +08:00
zhouxiang 29084f87d4 [ISSUE #3949] Sort code for rebase 2022-07-13 11:29:14 +08:00
kaiyi.lk e44f29a643 [ISSUE #3949] forwardMsgToDLQ for cluster mode; add ProducerGroupOfflineListener 2022-07-13 11:29:11 +08:00
zhouxiang 5cbb01e373 [ISSUE #3949] Implement Local transaction module 2022-07-13 11:29:11 +08:00
zhouxiang 77d7da51c4 [ISSUE #3949] Implement ack and nack 2022-07-13 11:29:11 +08:00
zhouxiang 0cd8ff08ee [ISSUE #3949] Remove consumerGroupInfo in PopMessageProcessor 2022-07-13 11:29:09 +08:00
rongtong 940d8d8255 Remove useless doAfterRpcFailure method in RPCHook (#4538) 2022-07-01 10:03:57 +08:00
zhichen cd24a24424 Fix bug for putting duplicated messsages while sending batch message (#4466) 2022-06-16 08:52:51 +08:00
zhangjidi2016andzhangjidi2016 d8c9bd38cb [ISSUE #4270]Log parameter error and optimize code (#4271) 
Co-authored-by: zhangjidi2016 <zhangjidi@cmss.chinamobile.com>
 2022-05-15 10:45:08 +08:00
rongtong a4cccea9db [ISSUE#4233] Move the capability of slaveActingMaster from container module to broker module 2022-05-06 10:21:14 +08:00
zhangyang e55db10c60 [ISSUE #4072] fix totalPollingNum count error (#4073) 
Signed-off-by: zhangyang <Git_Yang@163.com>
 2022-05-06 09:28:25 +08:00
cserwen 7a5fff4f10 [ISSUE #4192] Fix log split not work for dLedger in container (#4193) 2022-04-23 15:00:52 +08:00
cserwen 531cdb0bed sync message request mode from master (#4101) 2022-04-22 13:52:34 +08:00
cserwen d8119afb19 Use the right executor for EndTransactionProcessor (#4044) 2022-03-28 10:37:34 +08:00
RongtongJin 3cd0ec9a83 Merge remote-tracking branch 'apache/5.0.0-beta' into 5.0.0-beta-tmp 
# Conflicts:
#	broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
 2022-03-19 09:41:42 +08:00
cserwen 0b7291b35a [ISSUE #3503] bugfix: the consumeOffset will be set as 0 when getMessage returns null (#3504) 2022-03-18 10:49:02 +08:00
RongtongJin e678ee6f91 Add ASF header for unapproved file 2022-03-14 16:25:49 +08:00
RongtongJin 190617e8b9 Delete useless code file 2022-03-14 14:51:49 +08:00
rongtong cad0cfcece feature(broker & acl & client):[RIP-32]Support Slave Acting Master mode (#3978) 2022-03-14 14:51:10 +08:00
RongtongJin 3aa31a6a36 Merge remote-tracking branch 'apache/develop' into 5.0.0-alpha 
# Conflicts:
#	acl/pom.xml
#	broker/pom.xml
#	client/pom.xml
#	common/pom.xml
#	common/src/main/java/org/apache/rocketmq/common/MQVersion.java
#	distribution/pom.xml
#	example/pom.xml
#	filter/pom.xml
#	logging/pom.xml
#	namesrv/pom.xml
#	openmessaging/pom.xml
#	pom.xml
#	remoting/pom.xml
#	srvutil/pom.xml
#	store/pom.xml
#	store/src/test/java/org/apache/rocketmq/store/dledger/DLedgerCommitlogTest.java
#	test/pom.xml
#	tools/pom.xml
 2022-03-12 21:15:45 +08:00
RongtongJin 78dde88cf9 Prepare for next development iteration 2022-03-12 21:13:24 +08:00
tianliuliu 40d9505786 [ISSUE #3957] Fix LmqConsumerOffsetManager deserialize error (#3958) 
LmqConsumerOffsetManager deserialize error (#3958)
 2022-03-11 15:29:53 +08:00
RongtongJin a17fa7605c [maven-release-plugin] prepare release rocketmq-all-5.0.0-ALPHA 2022-03-11 10:37:19 +08:00
RongtongJin e33213c752 Upgrade version to 5.0.0-alpha-snapshot 2022-03-04 16:44:03 +08:00
RongtongJin 87d9614d34 Resolve all conflicts and pass all UTs 2022-03-04 16:38:04 +08:00
RongtongJin 0d15e6c2d5 Merge 5.0.0-alpha-merge with develop branch 2022-02-25 17:43:06 +08:00
tigerlee b606d9c638 [maven-release-plugin] prepare for next development iteration 2022-02-22 00:25:55 +08:00
tigerlee c7989f8574 [maven-release-plugin] prepare release rocketmq-all-4.9.3 2022-02-22 00:25:37 +08:00
tigerlee 13933297d1 [maven-release-plugin] prepare for next development iteration 2022-02-21 21:33:20 +08:00
tigerlee 666e96b6dd [maven-release-plugin] prepare release rocketmq-all-4.9.3 2022-02-21 21:33:02 +08:00
sunxi92 c1bb6aa27b [ISSUE #2986] Support for multiple ACL files in a fixed directory (#3761) 
* acl temp

* acl

* fix test case

* fix code style issues

* add considerations on compatibility to the original one ACL config file and scalability of supporting multiple config files in different directories.

* fix test case testWatch

* 1.fix some issues
2.add a detailed design document

* Add warn log when the accesskey is repeated in multiple ACL files.

* 1.Change the folder of acl configuration to conf/acl
2.Add the logic to check if path is a directory in the method of getAllAclFiles(String path)

* Add a parameter in AclFileWatchService constructor.

* Add logic to determine if path exists in the getAllAclFiles(String path) method in PlainPermissionManager.java and AclFileWatchService.java

* Fix the serialization problem of allAclFileVersion field in clusterAclConfigVersion command

* 1.Fix the serialization problem of allAclFileVersion field in clusterAclConfigVersion command
2.Improve the logic of updateAccessConfig method
 2022-02-19 09:52:31 +08:00
huangli 8fa9ca592c [ISSUE 3825] Use default SO_SNDBUF/SO_RCVBUF/WRITE_BUFFER_WATER_MARK value. (#3826) 
This commit may greatly increase thoughtput when network lantency is big or message size is big, especially for consumer.

In one broker (M/S sync master async flush), one producer send test.

250 byte body: 0.93x old version
4000 byte body: 3.85x of old version
16000 byte body: 6.07x of old version
100000 byte body: 7.93x of old version

The old version is 4.9.3-SNAPSHOT in this test. In this test the network latency from producer to broker is 1.61ms.
 2022-02-10 11:15:04 +08:00
zhangyang21 0b4adb49b4 [Assignment] Fix the risk of memory overflow caused by excessive popShareQueueNum. 
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
 2022-02-08 10:38:41 +08:00
cserwen fe88fb36a3 [ISSUE #3498] Make messages in reviveTopic more evenly written to different queues #3499 2022-02-08 10:38:41 +08:00
Hongjian Fei e8cf133874 [ISSUE #3708] Both CQ and BCQ need to be supported in DefaultMessageStore. (#3712) 
* [RIP-26] Both CQ and BCQ will be supported in DefaultMessageStore.

* [RIP-26] Both CQ and BCQ will be supported in DefaultMessageStore.
 2022-02-08 10:38:41 +08:00
cserwen 5ce1b88cf0 fix check style (#3703) 2022-02-08 10:38:41 +08:00
dongeforever a767cc1424 Fix test for consumer offset 2022-02-08 10:38:41 +08:00
dongeforever b3f9fbd3a7 Convert the consumer offset too 2022-02-08 10:38:41 +08:00
Hongjian Fei 18010a4d30 [ISSUE #3679] Support topic attributes (#3698) 
* [Feature] Support topic attributes.

* [Feature] Topic attributes unit-test.
 2022-02-08 10:38:41 +08:00
Erik1288 821b91f0a2 support batch consume-queue. 2022-02-08 10:38:41 +08:00
dongeforever b6ff649291 feat(all):new feature for static topic 2022-02-08 10:38:41 +08:00
tianliuliu 14b63ee550 [RIP-28] light message queue(LMQ) (#3694) 2022-01-13 19:15:42 +08:00
ltamber 0b612ff813 [ISSUE #3223]Optimize startup script to support greater jdk version (#3224) 
* support jdk9 and later version

* support jdk9 and later version
 2022-01-12 11:16:10 +08:00