mxsm
034d7389ba
[ISSUE #4788 ] Improvement controller quick_start.md file ( #4790 )
2022-08-07 10:45:09 +08:00
mxsm and Aaron Ai
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
刘亚洲
94572fad66
optimize statement ( #4699 )
...
* Update DefaultMQProducerImpl.java
Delete extra commas and format code
* Update design.md
optimize statement
* Update design.md
* Update design.md
2022-07-28 19:25:34 +08:00
mxsm
16416aaacf
[ISSUE #4673 ] DLedger quick start document optimize ( #4675 )
2022-07-23 22:00:44 +08:00
rongtong
4b5270a724
Optimizing documents and readme enables users to better use the controller mode ( #4666 )
2022-07-22 17:45:49 +08:00
RongtongJin
cae96c4008
Polish documents enables users to better understand the modes of DLedger, slaveActingMaster and controller
2022-07-22 15:11:32 +08:00
rongtong
8ccffa7e8a
[ISSUE #4646 ] Document modification of rocketmq 5.0 automatic master-slave switching ( #4645 )
...
* Document modification of rocketmq 5.0 automatic master-slave switching mode
* Polish the document of controller
2022-07-21 11:38:02 +08:00
RongtongJin
dd09f2b782
Merge remote-tracking branch 'apache/develop' into 5.0.0-beta-dledger-controller
...
# Conflicts:
# distribution/bin/mqshutdown
# pom.xml
2022-07-20 10:53:39 +08:00
zhouxiang
9fbaced20f
Merge branch 'develop' into feature/grpc-develop-v2
2022-07-14 14:15:30 +08:00
RongtongJin
67a526211e
Use ${dledger.version} instead of fixed version in pom file
2022-07-13 20:57:16 +08:00
RongtongJin
8dfa8813c4
Merge remote-tracking branch 'apache/develop' into 5.0.0-beta-dledger-controller
2022-07-13 15:10:01 +08:00
Heng Du
10326b479a
Merge pull request #4578 from apache/develop-merge-5.0.0
...
The code of 5.0.0-beta merge into develop branch
2022-07-13 14:54:23 +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
gap1994
c1261408f9
Fix misspelling
2022-07-08 15:46:23 +08:00
RongtongJin
a55a621594
Merge branch 'develop-merge-5.0.0' into 5.0.0-beta-dledger-controller
...
# Conflicts:
# broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
# common/src/main/java/org/apache/rocketmq/common/protocol/RequestCode.java
# store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
# tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
2022-07-08 15:35:41 +08:00
RongtongJin
833e9e0e07
Polish conf/container directory
2022-07-08 15:16:18 +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
Oliver
418a5b2eaf
Update doc ( #4548 )
2022-07-06 09:29:56 +08:00
RongtongJin
1b77be4d28
Add back haConnectionStateNotificationService to HAService
2022-06-30 09:21:20 +08:00
ethan
c204199e1d
fix notAvailableDuration description in doc file ( #4511 )
2022-06-25 11:49:12 +08:00
rongtong
a8549e24a1
Add deploy and upgrade guide document for controller mode ( #4476 )
...
* Add deployment and upgrade guide document
* Minor fix
2022-06-18 14:24:37 +08:00
RongtongJin
c2b21e4e2d
Some minor document fixes
2022-06-16 14:32:21 +08:00
rongtong
3fbcad5f91
Remove allAckInSyncStateSet in GroupCommitRequest and use ackNums = -1 instead ( #4467 )
...
* Remove allAckInSyncStateSet in GroupCommitRequest and use ackNums = -1 instead
* Pass the UT
* Format the code style
* Do the same for batch messages and polish the code
* Polish the constant name
* Polish the document
* Polish the document
2022-06-16 11:58:11 +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
RongtongJin
3e0a41d4cc
Polish the mq controller document
2022-06-06 17:46:01 +08:00
hzh0425
55a0e7b884
[Summer of code] Add design and quick_start document for controller mode ( #4413 )
...
* add design document
* add quickstart document
* review
* add dledgerController design
* add license
2022-06-06 11:36:03 +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 and 文泊
726ed7298c
fix broker log path typo ( #4307 )
...
Co-authored-by: 文泊 <xll333993@alibaba-inc.com >
2022-05-15 10:48:31 +08:00
RongtongJin
d6a53f9c29
Polish the document of SlaveActingMasterMode.md and QuorumACK.md
2022-05-01 16:16:09 +08:00
samz406
9de7be4785
update design doc ( #4205 )
2022-04-26 10:08:11 +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
gogodjzhu and djzhu
2897bbfba2
[ISSUE #4150 ] Fix spelling mistakes on docs ( #4141 )
...
Co-authored-by: djzhu <zhudejun1@huya.com >
2022-04-13 09:16:29 +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#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
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
yuz10
336939080e
[ISSUE #4035 ] rename some commands ( #4036 )
...
* rename some commands
* update doc
2022-04-01 08:58:27 +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
hn and hening
1a72ffd200
fix docs error ( #4023 )
...
Co-authored-by: hening <ninghe.hn@alibaba-inc.com >
2022-03-24 10:13:12 +08:00
rongtong
fb9e3f05bb
feature(logging&tools&distribution&docs):[RIP-31][PART-A]Support RocketMQ BrokerContainer ( #3977 )
2022-03-14 14:50:48 +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
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#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
hn and hening
52700533b0
fix some docs error ( #3926 )
...
* fix some docs error
* remove useless code
Co-authored-by: hening <ninghe.hn@alibaba-inc.com >
2022-03-04 16:11:07 +08:00
RongtongJin
0d15e6c2d5
Merge 5.0.0-alpha-merge with develop branch
2022-02-25 17:43:06 +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
ca92d367fd
Update design.md ( #3835 )
...
* Update .travis.yml
Depracated MODERATE noisy mail for dev@rocketmq.apache.org . Still Failing: apache/rocketmq#5670 (5.0.0-alpha-static-topic - 5ebc327#3735 )
* Update design.md
delete redundant text
Co-authored-by: von gosling <vongosling@apache.org >
Co-authored-by: ZhangJian He <shoothzj@gmail.com >
2022-02-09 19:08:43 +08:00
dongeforever
b3f9fbd3a7
Convert the consumer offset too
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
彭小漪
30d1c58a0c
[ISSUE #3801 ] Polish the document 'CLITools.md'. ( #3802 )
2022-01-27 14:29:32 +08:00
mxsm