opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-29 04:13:00 +08:00
Code Issues Packages Projects Releases Wiki Activity
9,189 Commits 72 Branches 40 Tags
develop
Commit Graph

241 Commits

Author SHA1 Message Date
LeiXiaoGao c4ae761f09 docs: fix broker container reference and producer typos (#10449) 2026-06-20 10:54:59 +08:00
KaiQuan Chen 226e24faf6 Fix outdated constructor signatures in trace documentation (#10501) 
The two-argument constructors DefaultMQProducer(String, boolean) and
DefaultMQPushConsumer(String, boolean) do not exist in 5.x.
Updated to use the three-argument form with null for the default
trace topic.

Fixes #10500
 2026-06-15 20:25:30 +08:00
quzizii c4f18d96bb [DOCS] Fix typos in documentation filenames (#10505) 
Rename Design_LoadBlancing.md to Design_LoadBalancing.md
Rename Design_Trancation.md to Design_Transaction.md
 2026-06-15 09:43:26 +08:00
lsq3497 63394315af docs: fix inaccurate examples and typos across developer guides (#10456) 2026-06-10 19:58:04 +08:00
LeiXiaoGao 86ccea0777 docs: fix broker IP typo in startup examples (#10440) 2026-06-10 19:54:45 +08:00
lizhimins 980f3d7f55 [ISSUE #10373] Quarantine flaky tests and add detection plan docs (#10374) 
* [ISSUE #10373] Quarantine flaky tests and add detection plan docs

Ran all RocketMQ module tests 100x across 10 ECS nodes to identify
non-deterministic failures. Quarantined methods with @Ignore across
broker, client, filter, and tieredstore modules.

Flaky tests quarantined:
- broker: LiteLifecycleManagerTest#testCleanByParentTopic (2%)
- broker: ConsumerOrderInfoManagerLockFreeNotifyTest#testRecover (2%)
- broker: TransactionalMessageServiceImplTest#testDeletePrepareMessage_maxSize (1%)
- client: DefaultMQConsumerWithTraceTest#testPullMessage_WithTrace_Success (1%)
- client: DefaultMQLitePullConsumerWithTraceTest#testSubscribe_PollMessageSuccess_WithCustomizedTraceTopic (5%)
- client: DefaultMQLitePullConsumerWithTraceTest#testSubscribe_PollMessageSuccess_WithDefaultTraceTopic (6%)
- filter: BloomFilterTest#testCheckFalseHit (1%)
- tieredstore: IndexStoreServiceTest#queryCrossFileBoundaryTest (35%)
- tieredstore: IndexStoreServiceTest#concurrentGetTest (1.5%)

Additional changes:
- LiteLifecycleManagerTest: Switch to MockitoJUnitRunner.Silent
- Add flaky test detection plan docs (CN + EN)

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* [ISSUE #10373] Quarantine flaky PopPriorityIT and fix test cases

- Quarantine PopPriorityIT at class level (multiple methods fail
  intermittently with 'expected:<8> but was:<2>' due to async race)
- Fix ConsumerOrderInfoManagerLockFreeNotifyTest
- Fix IndexStoreServiceTest

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* [ISSUE #10373] Fix flaky test detection plan docs path and naming

Move English doc from docs/cn/ to docs/en/ and rename both files
to match existing docs naming convention (underscore + PascalCase).

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

---------

Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>
 2026-05-25 17:36:36 +08:00
H145608 eb95ba3419 [DOCS] Fix typo in Troubleshooting.md filename (#10360) 
Rename Troubleshoopting.md -> Troubleshooting.md
The original filename had a spelling error ('shoopting' instead of 'shooting').

Co-authored-by: H145608 <1404499274@qq.com>
 2026-05-25 11:48:45 +08:00
lizhimins 7e5d22dff8 [ISSUE #10334] Make native CqCompactionFilter shim self-contained without rocksdbjni dependency (#10371) 2026-05-25 10:07:16 +08:00
H145608 54708be637 [DOCS] Update example dependency version from 4.3.0 to 5.5.0 (#10349) 
Update rocketmq-client dependency version in Example_Simple.md documentation
from the outdated 4.3.0 to the latest stable release 5.5.0

Co-authored-by: H145608 <1404499274@qq.com>
 2026-05-22 22:42:52 +08:00
lizhimins 61c493c068 [ISSUE #10334] Support native CqCompactionFilter with cross-platform JNI shim (#10335) 2026-05-21 10:12:14 +08:00
majialong 4a29b7e0bf [ISSUE #10077] Support password-encrypted private keys for Proxy TLS (#10078) 
* [ISSUE #10077] Support password-encrypted private keys for Proxy TLS

* Fix bazel error

* Fix unit test

* Add comments
 2026-03-13 14:27:49 +08:00
Sebastien Dionne 4b5f8665f9 Fix typos and linguistic errors in documentation (#9748) 
Signed-off-by: Sebastien Dionne <survivant00@gmail.com>
 2025-10-09 13:58:56 +08:00
DivyanshIITB dee51095e2 [ISSUE #8243] Update Configuration Docs for RocketMQ 5.x Compatibility (#9258) 2025-03-20 11:41:10 +08:00
Lynx ff94b99758 [ISSUE #9155] Update doc Deployment Context 
Co-authored-by: lynx <lynx@qq.com>
 2025-01-28 10:08:32 +08:00
luozongle01 6c90aace36 [ISSUE #8802] Update controller design.md (#8803) 2024-10-10 09:48:30 +08:00
yx9o 945e7eacb1 [ISSUE #8604] Fix doc typo (#8605) 
* [ISSUE #8604] Fix doc typo

* [ISSUE #8604] Fix doc typo
 2024-09-20 17:46:22 +08:00
Jay Ko 72bd03c47c fix document typo (#7721) 2024-03-13 12:52:42 +08:00
Ao Qiao 0f01df460f [ISSUE 7265] Doc: Adding how to debug in Idea document (#7266) 2023-10-16 11:37:25 +08:00
rongtong ea3298065c Polish the persistent_unique_broker_id document (#6817) 2023-05-26 21:51:24 +08:00
maclong1989 224d660670 doc: fix typo in operation.md (#6799) 
Signed-off-by: jiangyl3 <jiangyl3@asiainfo.com>
Co-authored-by: jiangyl3 <jiangyl3@asiainfo.com>
 2023-05-25 17:51:46 +08:00
Oliver 9b90b5b70a [ISSUE #6445] Fix the attribute of the compaction topic doc (#6451) 2023-03-27 15:26:10 +08:00
mxsm 8ddf2fdd42 [ISSUE #6469]Translation persistent_unique_broker_id.md (CN->EN) (#6470) 2023-03-25 17:13:13 +08:00
guyinyou c17baf1e33 [ISSUE #6386] Some improvements for compactionTopic (#6387) 
* 1、Graceful shutdown needs to wait for the compactionTopic to build the index
2、Exception handling that may occur when adding pullMessageFromMaster
3、Update usage docs

* fix doc

---------

Co-authored-by: guyinyou <guyinyou.gyy@alibaba-inc.com>
 2023-03-22 11:23:13 +08:00
TheR1sing3un 1ad1c4d825 docs(docs): add docs about how to update to BrokerId version 
1. add docs about how to update to BrokerId version
 2023-03-14 09:40:15 +08:00
yx9o b1d87f405e [ISSUE #5821] Remove unnecessary Chinese in QuorumACK.md document. 2023-01-05 09:07:08 +08:00
mxsm dd4d188bd1 [ISSUE #5789]Translation controller design.md chinese document to english document (#5790) 2022-12-31 11:42:41 +08:00
mxsm 5de60cf591 [ISSUE #5791]Fix controller deploy.md and quick_start.md link not correct (#5792) 
* [ISSUE #5791]Fix controller deploy.md and quick_start.md link not correct

* polish document
 2022-12-31 11:39:46 +08:00
mxsm 8d65abf4af [ISSUE #5793]Translation QuorumACK.md chinese document to english document and polish cn document (#5794) 
* [ISSUE #5793]Translation QuorumACK.md chinese document to english document and polish cn document

* polish cn document
 2022-12-31 11:39:33 +08:00
mxsm b95f69a781 [ISSUE #5770]Translation controller quick_start.md chinese document to english document (#5771) 
* [ISSUE #5770]Translation controller quick_start.md chinese document to english document
 2022-12-30 22:49:18 +08:00
mxsm 70788a2200 [ISSUE #5785]Translation controller deploy.md chinese document to english document (#5786) 2022-12-30 11:06:50 +08:00
mxsm d63fb923ce [ISSUE #5730] Translate chinese to english in API_Reference_DefaultMQProducer.md document (#5731) 2022-12-18 20:00:44 +08:00
Zhouxiang Zhan f55e6bace3 [ISSUE #5506] Add create topic in docs (#5522) 2022-11-14 17:11:39 +08:00
ltamber e38da5590f [ISSUE #3799]main compaction process (#5351) 
* add compaction delete policy

* wrapper message ext encoder

* fix

* cleanup policy

* cleanup policy

* wrapper message ext encoder

* Revert "cleanup policy"

This reverts commit da76a4820b.

* cleanup policy

* topic compaction

* compaction recovery and user document

* use cleanup policy

* fix
 2022-10-24 16:21:39 +08:00
Zhanhui Li 9b95b9e6c8 Update deploy_guide.md (#5099) 
* Update deploy_guide.md

* Update docs/en/proxy/deploy_guide.md

Capitalize Mode

Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>

* Update docs/en/proxy/deploy_guide.md

Co-authored-by: Oliver <wqdyxnbd@163.com>

Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
Co-authored-by: Oliver <wqdyxnbd@163.com>
 2022-09-19 14:10:39 +08:00
zhaows 45937936b8 Fixed intermixing of punctuation marks in English documents (#5086) 2022-09-18 11:23:48 +08:00
mxsm a3e54fcb1b [ISSUE #4993] Polish the documents for mq Dledger Quick Deployment (#4994) 2022-09-05 08:27:48 +08:00
Jun 0eca69bf25 fix #1942 push consumer doc error (#1944) 2022-08-23 19:32:04 +08:00
mxsm b875b3309a [ISSUE #4709] fix method is on the same line as @Override annotation (#4717) 
Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
 2022-08-01 20:42:34 +08:00
mxsm 16416aaacf [ISSUE #4673] DLedger quick start document optimize (#4675) 2022-07-23 22:00:44 +08:00
zhouxiang 9fbaced20f Merge branch 'develop' into feature/grpc-develop-v2 2022-07-14 14:15:30 +08:00
zhouxiang 374b0686a0 [ISSUE #3949] Add README 2022-07-13 11:32:56 +08:00
zhouxiang 2a53918817 [ISSUE #3949] Add deploy guide 2022-07-13 11:29:28 +08:00
RongtongJin 3fadc8f30c Merge branch '5.0.0-beta' into develop 
# Conflicts:
#	acl/pom.xml
#	broker/pom.xml
#	broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
#	broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
#	broker/src/main/java/org/apache/rocketmq/broker/plugin/MessageStoreFactory.java
#	broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
#	broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
#	broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
#	broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
#	broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
#	broker/src/main/java/org/apache/rocketmq/broker/processor/ForwardRequestProcessor.java
#	broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
#	broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
#	broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
#	broker/src/main/java/org/apache/rocketmq/broker/transaction/jdbc/JDBCTransactionStore.java
#	broker/src/test/java/org/apache/rocketmq/broker/processor/SendMessageProcessorTest.java
#	client/pom.xml
#	client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
#	client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
#	client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
#	client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
#	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
#	client/src/test/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumerTest.java
#	common/pom.xml
#	common/src/main/java/org/apache/rocketmq/common/MQVersion.java
#	common/src/main/java/org/apache/rocketmq/common/protocol/RequestCode.java
#	common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
#	common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java
#	common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java
#	common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java
#	common/src/main/java/org/apache/rocketmq/common/utils/ServiceProvider.java
#	common/src/test/java/org/apache/rocketmq/common/message/MessageDecoderTest.java
#	distribution/pom.xml
#	example/pom.xml
#	filter/pom.xml
#	logging/pom.xml
#	logging/src/main/java/org/apache/rocketmq/logging/inner/Level.java
#	namesrv/pom.xml
#	namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java
#	namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
#	namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
#	openmessaging/pom.xml
#	pom.xml
#	remoting/pom.xml
#	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
#	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
#	remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java
#	remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSerializable.java
#	srvutil/pom.xml
#	store/pom.xml
#	store/src/main/java/org/apache/rocketmq/store/CommitLog.java
#	store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
#	store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
#	store/src/main/java/org/apache/rocketmq/store/MultiDispatch.java
#	store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
#	store/src/main/java/org/apache/rocketmq/store/ha/HAConnection.java
#	store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
#	store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
#	store/src/main/java/org/apache/rocketmq/store/logfile/DefaultMappedFile.java
#	store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
#	store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreCleanFilesTest.java
#	store/src/test/java/org/apache/rocketmq/store/MultiDispatchTest.java
#	store/src/test/java/org/apache/rocketmq/store/dledger/DLedgerCommitlogTest.java
#	test/pom.xml
#	tools/pom.xml
#	tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
#	tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
#	tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java
#	tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
#	tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java
 2022-07-08 15:03:54 +08:00
ethan c204199e1d fix notAvailableDuration description in doc file (#4511) 2022-06-25 11:49:12 +08:00
cnScarb fcfe26e444 [ISSUE #4037] Add DeleteExpiredCommitLogSubCommand (#4038) 
* [ISSUE #4037] Merge with origin

* [ISSUE #4048] Add assertions for DeleteExpiredCommitLogSubCommandTest
 2022-06-14 17:18:14 +08:00
Dios314 0fca6df7f4 Something in docs may cause confusion (#4403) 2022-06-04 16:10:16 +08:00
Ni Ze 0bc3b991e1 [ISSUE #4226] Message length exceeds the maximum length when sendback (#4338) 
* fix(bug)msg length exceeds the maximum length when sendback

* fix(store) MessageStoreConfig: maxMessageBodySize -> maxMessageSize, for compatibility

* style(formatting) commigLog
 2022-06-01 13:51:07 +08:00
chris-joys e05b098327 [ISSUE #4067] fix: Add TLS configuration documents. (#4387) 
* [ISSUE #4067] fix: Add TLS configuration documents.

* Fix spelling mistakes

Update document to fix spelling mistakes.

* [ISSUE #4067] fix: Update document to fix spelling mistakes.
 2022-05-29 18:43:07 +08:00
gobbq 726ed7298c fix broker log path typo (#4307) 
Co-authored-by: 文泊 <xll333993@alibaba-inc.com>
 2022-05-15 10:48:31 +08:00
gogodjzhu 2897bbfba2 [ISSUE #4150] Fix spelling mistakes on docs (#4141) 
Co-authored-by: djzhu <zhudejun1@huya.com>
 2022-04-13 09:16:29 +08:00