This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch 5.0.0-preview
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
omit dd09ba1 merger from develop branch and fix compile error
omit 2bf133b Merge branch 'develop' into 5.0.0-preview
omit 1e8e728 Merge pull request #3295 from lwclover/develop
omit 67f4357 add checkstyle to travis ci
omit 0748aa0 Merge pull request #3322 from 844392610/develop_xm
omit ee55441 Merge pull request #3335 from zhouwentong1993/patch-1
omit a9837d9 Merge pull request #2965 from
zhangjidi2016/add_getConsumerConfig_command
omit 67ccb7f Merge pull request #2729 from wz2cool/master
omit 0de4038 [ISSUE #3361]DefaultMQProducer's constructor can call the
overloaded constructor. (#3362)
omit a9ae546 Merge pull request #2437 from maixiaohai/DLQ_perm
omit 502ca60 fix ci
omit 311d76f [ISSUE 3194] [PART C] Replace AtomicLong with LongAdder in
StatsItem.java to improve performance (#3351)
omit 147d23e [ISSUE #3281 ][acl] fix fail to delete topic perm list and
global white address(#3128) (#3280)
omit f9a0f53 Merge pull request #1858 from coder-zzzz/github_features/#1848
omit bf343a3 [ISSUE #3225]change Random to ThreadLocalRandom in broker
omit 83b04d0 [ISSUE #3346]Avoid double parse remoteAddr in rpcHook call
omit 7314183 netadress toUpperCase beforehand
omit 53c55f7 [ISSUE #3245] Use df algorithm to calculate the disk used
ratio
omit 3604100 [ISSUE #3314] Make mqClientApi request timeout settable
omit 564ee29 [ISSUE] Add get stats and single queue stats for schedule
topic
omit 8434658 [ISSUE #2724] Resend message to DLQ directly when max
reconsume times reach (#3318)
omit 4b7a90a [#3326] fix send trace fail if useTLS=true (#3325)
omit b2aa85d [ISSUS #3340] (doc)add hyperlink for client repos in the
introduction. (#3338)
omit ef7685d [ISSUE #3341](doc)fix typo in update operation.md
omit 7519a53 [ISSUE 3333] Remove commons-codes dependency (#3334)
omit ced5843 Update rocketmq client maven version
omit fea769d [ISSUE #3284]Optimize the buildMessage method (#3324)
omit 97da4ac Improve performance of expandIP, and readable
omit 6358b3c Revert "Improve performance of expandIP, and readable"
omit 7a6c374 Revert "Improve performance of expandIP, and readable"
omit d7a830c [ISSUE 3194] [PART A] Use LongAdder instead of AtomicLong in
BrokerStatsService to improve performance. (#3195)
omit 2baae14 Improve performance of expandIP, and readable
omit 857d28d [ISSUE #3284]Optimizing benchmark code (#3317)
omit 2cac866 [ISSUE #3136] TraceDataEncoder add SubAfter trace bean
timestamp (#3137)
omit 401dc8e production level pull api demo
omit 7c7e9ac [ISSUE #3284]Optimizing benchmark code (#3285)
omit 9e66da4 Merge branch 'develop_include_prs_after_4.9.1_version',
remote-tracking branch 'origin' into develop
omit fb8bc64 Merge branch 'develop'
omit 2820e47 [ISSUE #3215] polish litePullConsumer seek logic #3216
omit a7e71cb [maven-release-plugin] prepare for next development iteration
omit a1bfe1a [maven-release-plugin] prepare release rocketmq-all-4.9.1
omit 44bdeed [ISSUE 3203] Replace the class 'StringBuffer' by
'StringBuilder' (#3204)
omit 3a2b172 [ISSUE #3006]Replace ScheduledExecutorService instead of
Timer to avoid affecting other tasks during exception (#3001)
omit 0fdc73d Merge pull request #3033 from
zyh-future/zyh_asuncproducer_doc_fix
omit bb34171 [maven-release-plugin] prepare for next development iteration
omit e9c4253 [maven-release-plugin] prepare release rocketmq-all-4.9.1
omit ec985ee Merge pull request #3206 from
zongtanghu/develop_fix_4.9.1_codestyle
omit 73db297 [#Issue3205]Fix the issue of code style in client and broker
modules.
omit 5e58893 prepare to release rocketmq 4.9.1 version
omit 9e8fea9 Merge pull request #3176 from yuz10/develop3
omit 94abced [ISSUE #3199] Two timed task for RequestFutureTable (#3202)
omit 3e01424 Merge pull request #3134 from areyouok/dev_speed_G
omit 2509b0e Merge pull request #2961 from areyouok/dev_speed_F
omit d21266d Merge branch 'develop' into develop3
omit d067bfc [ISSUE #3192] Make free disk value more accurate
omit a23df96 [ISSUE 2883] Improve performance of
string2messageProperties/messageProperties2String, and save 1 byte for each
message.
omit 1eaa38f [ISSUE #3200] Fix code style in 'NettySystemConfig.java'
omit a137e48 [ISSUE 2883] [Part G] Optimise parse performance for
SendMessageRequestHeaderV2, unit test
omit 1b757b4 [ISSUE #3196] Check if "requestHeader" is null before
"requestHeader.getTopic()"
omit 17b9efe [ISSUE #3177]updateAclConfig in all brokers. (#3184)
omit 6f7b0d6 Merge pull request #3182 from lwclover/develop
omit b68724b [ISSUE #3030]Remove the -Xmn JVM parameter when using G1
(#3170)
omit 0325772 [ISSUE #2883] [Part E] Improve produce performance in M/S
mode. (#2889)
omit 360b616 [ISSUE #3185]remove the arm machine test in travis ci
omit 3aa4943 fix checkstyle
omit 66eeaed #3175 check acl config before update. otherwise broker may
fail to start
omit 72128f7 Merge branch 'develop' of
https://github.com/lwclover/rocketmq-2.git into develop
omit 800421e registerProducer & unregisterProducer add synchronization
too, how about add for producer
omit 36e6687 Merge pull request #3120 from lwclover/develop
omit d60643a Merge pull request #2720 from EZLippi/feature/issue2715
omit 8eb275f Merge branch 'apache:develop' into develop
omit 9a9039e Merge pull request #3032 from messense/upgrade-netty-all
omit 1e982af Merge pull request #2995 from yuz10/develop4
omit c63ec20 Merge pull request #2058 from RealBar/fix/issue2055
omit 74aa3e0 Update SendMessageProcessor.java
omit 765cac3 Merge pull request #3025 from Git-Yang/statistics_bug
omit 35a15b6 Merge pull request #3022 from heihaozi/maxReconsumeTimes
omit 011035f Merge pull request #3163 from yuz10/develop6
omit 5b945a9 Merge pull request #3158 from
Zanglei06/fix_rmq_client_offset_dev
omit bb9a70c Merge pull request #3165 from
zhangjidi2016/fix_checkstyle_error
omit 18e2a26 [ISSUE #3164]Fix the checkstyle error
omit df88bce add msgTraceEnable config in transaction producer benchmark
omit 5808772 fix checkstyle fail
omit 40e1435 #2990 Add document
omit a20f31b Limit event trigger
omit 39f549a Update greetings.yml
omit cfadd4d Update greetings.yml
omit d83b7e5 Fix typo
omit d7c2d25 [ISSUE #2708] fix offset rollback when fetch offset from
broker exception
omit 6aabf77 Merge pull request #3047 from qingjiyuji/develop
omit 36333ce Merge pull request #3157 from yglovewms/yeyi
omit 04c7354 delete the unuse code
omit a315833 Merge pull request #3132 from
zhangjidi2016/fix_update_globalWhiteAddresses
omit cf0819e Merge pull request #3144 from A-Zee029/master
omit 5a2aa7e Update greetings.yml
omit 15b0cde Update greetings.yml
omit d1f9915 Place into workflows directory
omit 5bd7ccc Add little rocketmq robot
omit e4daba5 Merge pull request #3042 from haoran-pku/master
omit 89d9ed7 Merge pull request #3100 from sunbufu/fix-issue-603
omit 17a8e93 fix spell error
omit 30058cf Merge pull request #3038 from IntroDrop/develop
omit 5908ca7 Merge pull request #3056 from zplovekq/doc_add
omit 69e8185 Merge pull request #3036 from Cu-Cu/master
omit e1f94aa Merge pull request #3034 from PatrickkZ/develop
omit 2bd0676 Merge pull request #3116 from trdmm/develop
omit b822db0 Fix DLQ can't be query sometimes
omit 3efcd85 Merge pull request #3122 from panzhi33/master
omit 589e87c [ISSUE #3099] Fix the incorrect judegment 'writePos -
lastCommittedPosition > commitLeastPages' in the method 'commit0' of class
'MappedFile' (#3125)
omit 2fc1148 Merge pull request #3111 from codersfarm/develop
omit b13a4c8 [ISSUE 2883] [Part G] Optimise parse performance for
SendMessageRequestHeaderV2
omit 4c1998a retrigger ci
omit 44e2669 [ISSUE #3128] fix the delete global white addresses
omit 3183122 Eliminate array copy (#2886)
omit d65778f [ISSUE #2883] [Part B] Improve produce performance in M/S
mode. (#2885)
omit cba3e05 Merge pull request #3124 from lizhiboo/add_trace_test_case
omit 7c36468 [ISSUE #3089] fix Print log format is incorrect in
NettyRemotingAbstract class (#3126)
omit 6591589 [ISSUE #3118] Fix type conversion exception
omit c75ef50 Merge branch 'apache:develop' into develop
omit bc73c32 use String.format() in warn log.
omit 83efcce Merge remote-tracking branch 'upstream/develop' into
fix-issue-603
omit b74c48b add trace data format test case
omit 2a63717 Merge pull request #2882 from zhurunhua/RocketMQ-zhurunhua
omit 062e6f3 revert [ISSUE #2442] when happening system busy, retry
omit f4b3d4f fix namesrv endpoint
omit 7029545 Merge branch 'apache:develop' into develop
omit 4e5a60c [ISSUE #2442] when happening system busy, retry
omit d93dc4d Merge branch 'apache:develop' into develop
omit 36422c5 [ISSUE #3066]producing a ghost consumer
omit 94e0899 [ISSUE #3097] docs remove obsolete/error configuration
omit 9a5ec90 [ISSUE #3109]Return a no-support value when not match any
request code
omit 7f1cb79 remove useless code
omit 92f2d03 log exception stack
omit df35edf Merge pull request #3088 from sunbufu/fix-a-typo
omit 95a6275 typo
omit fcc20de [ISSUE #3059] typo transactional message wiki
omit a2f8810 [ISSUE #2988] fix fail to send trace of last message before
shutting down producer
omit 6b519ef [ISSUE #3068] remove jaeger tracing dependency in release
package
omit a0a2192 [ISSUE #2873] add benchmark for batch message
omit d0d2f15 add chinese version of FAQ.md
omit 893e8fd code style(client):polish lite pull consumer code style
omit 622bbbf add some doc of the API_Reference_DefaultMQProducer of
English.
omit 61cd395 code style(client):polish lite pull consumer code style
omit a99cf37 Add Chinses Version Doc of Example_Simple.md
omit 0cc5ad2 add Chinese version of Example_Batch
omit 23f3893 Add a Chinese version of Deployment.md
omit 278d328 add Chinese version
omit 361eb8d Upgrade netty-all dependency version to 4.1.65.Final
omit 160c577 test(benchmark): support delay message test (#3010)
omit d8dec65 add different send examples
omit 9d4e8de Looking at the Chinese document, I found that the subtraction
operation of countdown timer is missing in asynchronous message push, so I
downloaded the code. I found that someone added subtraction operation to the
demo code in 18 years, but the document was not repaired, so I did this repair
omit 25f6711 [statistics] Fix the inconsistency of
putMessageDistributeTime statistics
omit 2b236c3 [ISSUE 3019] Fixed bug with batch-sent message statistics
omit ece364a Improve the comment of maxReconsumeTimes
omit e126310 [ISSUE #2997] Add a Chinese version of Configuration_System.md
omit e5a3f7d Merge pull request #2888 from areyouok/dev_speed_D
omit a92996a Merge pull request #3005 from lfz757077613/develop
omit 0c36d14 remove SubAfter field
omit 93dd086 AsyncTraceDispatcher unique groupName
omit b9c108b Merge remote-tracking branch
'origin/develop_include_3_commits' into develop
omit 57c166b Merge pull request #2991 from yuz10/develop4
omit 2fe6dc3 #2990 Add message tracing switch in sendMessage command of
mqadmin
omit 52348b8 Merge pull request #2977 from ferris-cx/master
omit a1babab [maven-release-plugin] prepare for next development iteration
omit a027f8d [maven-release-plugin] prepare release rocketmq-all-4.9.0
omit 317fd7e Changing the comma input method
omit f42db53 Changing the comma input method
omit 46bd4be [ISSUE #2964] Add a query consumer config command in mqadmin.
omit 20b6cdd [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.
omit 4f33895 Merge branch 'develop' into RocketMQ-zhurunhua
omit b186bcd update the option's description of consumer.sh
omit 5fe0041 Change default value of some parameters:
sendMessageThreadPoolNums/useReentrantLockWhenPutMessage/flushCommitLogTimed/endTransactionThreadPoolNums
omit 22647de update the option's description of updateAccessConfig command
omit 56c3ad8 update the option's description of deleteAccessConfig command
omit 59cbbc4 feat: add some test case
omit d6da221 fix import issue
omit 0363be1 add response code for retrying
omit 67ceb64 fix: add license
omit 98237b1 feat: add some test case
omit 03adb63 feat: add some test case
omit 33a533b feat: add some test case
omit b954d35 feat: issue2715, make netty parameter configure by system
property
omit 0a16ff6 DLQ topic default perm change
omit bc3eeed fix: fix issue 2055
omit 6cee569 duplicate doAfterRpcHooks
omit 1f2b84b fix #1883 fix wipeWritePerm doc desc
omit 8d964f4 close #1848
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/5.0.0-preview (48d3c7e)
\
O -- O -- O (dd09ba1)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/greetings.yml | 29 -
README.md | 2 +-
.../org/apache/rocketmq/acl/common/AclUtils.java | 68 +-
.../rocketmq/acl/plain/PlainPermissionManager.java | 53 +-
.../acl/plain/RemoteAddressStrategyFactory.java | 2 +-
.../apache/rocketmq/acl/common/AclUtilsTest.java | 1 -
.../acl/plain/PlainAccessValidatorTest.java | 53 +-
.../broker/pagecache/ManyMessageTransfer.java | 27 -
.../broker/pagecache/OneMessageTransfer.java | 27 -
.../broker/pagecache/QueryMessageTransfer.java | 27 -
.../broker/plugin/AbstractPluginMessageStore.java | 4 +-
.../processor/AbstractSendMessageProcessor.java | 87 +--
.../broker/processor/AdminBrokerProcessor.java | 20 +-
.../broker/processor/ReplyMessageProcessor.java | 4 +-
.../broker/processor/SendMessageProcessor.java | 120 +--
.../AbstractTransactionalMessageCheckListener.java | 2 +
.../DefaultTransactionalMessageCheckListener.java | 4 +-
.../AbstractSendMessageProcessorTest.java | 82 --
client/pom.xml | 4 +
.../org/apache/rocketmq/client/ClientConfig.java | 13 +-
.../client/consumer/DefaultLitePullConsumer.java | 4 +-
.../client/consumer/DefaultMQPushConsumer.java | 18 +-
.../rocketmq/client/impl/MQClientAPIImpl.java | 28 +-
.../ConsumeMessageConcurrentlyService.java | 28 +-
.../consumer/ConsumeMessageOrderlyService.java | 4 +-
.../impl/consumer/DefaultLitePullConsumerImpl.java | 64 +-
.../impl/consumer/DefaultMQPushConsumerImpl.java | 2 +-
.../client/impl/consumer/RebalanceImpl.java | 2 +-
.../impl/consumer/RebalanceLitePullImpl.java | 3 +-
.../client/impl/factory/MQClientInstance.java | 42 +-
.../impl/producer/DefaultMQProducerImpl.java | 60 +-
.../client/producer/DefaultMQProducer.java | 54 +-
.../client/producer/RequestFutureTable.java | 7 -
.../client/trace/AsyncTraceDispatcher.java | 74 +-
.../rocketmq/client/trace/TraceDataEncoder.java | 1 +
.../apache/rocketmq/client/trace/TraceView.java | 4 +-
.../rocketmq/client/impl/MQClientAPIImplTest.java | 27 -
.../ConsumeMessageConcurrentlyServiceTest.java | 2 +-
.../trace/DefaultMQConsumerWithTraceTest.java | 9 -
.../DefaultMQLitePullConsumerWithTraceTest.java | 12 +-
.../trace/DefaultMQProducerWithTraceTest.java | 10 -
.../client/trace/TraceDataEncoderTest.java | 106 +--
.../rocketmq/client/trace/TraceViewTest.java | 4 +-
.../org/apache/rocketmq/common/BrokerConfig.java | 8 +-
.../java/org/apache/rocketmq/common/MixAll.java | 1 -
.../java/org/apache/rocketmq/common/UtilAll.java | 33 +-
.../apache/rocketmq/common/message/Message.java | 11 +-
.../rocketmq/common/message/MessageDecoder.java | 41 +-
.../rocketmq/common/protocol/NamespaceUtil.java | 2 +-
.../rocketmq/common/protocol/RequestCode.java | 2 -
.../namesrv/AddWritePermOfBrokerRequestHeader.java | 39 -
.../AddWritePermOfBrokerResponseHeader.java | 38 -
.../apache/rocketmq/common/stats/StatsItem.java | 23 +-
.../apache/rocketmq/common/stats/StatsItemSet.java | 8 +-
.../common/utils/NameServerAddressUtils.java | 1 -
.../org/apache/rocketmq/common/UtilAllTest.java | 14 -
.../common/message/MessageDecoderTest.java | 108 ---
.../rocketmq/common/stats/StatsItemSetTest.java | 4 +-
.../rocketmq/common/utils/IOTinyUtilsTest.java | 4 +-
distribution/benchmark/batchproducer.sh | 18 -
distribution/bin/runbroker.cmd | 2 +-
distribution/bin/runbroker.sh | 2 +-
distribution/bin/runserver.cmd | 2 +-
distribution/bin/runserver.sh | 6 +-
distribution/release.xml | 4 -
docs/cn/Configuration_System.md | 70 --
docs/cn/Deployment.md | 159 ----
docs/cn/Example_Batch.md | 82 --
docs/cn/Example_Delay.md | 85 ---
docs/cn/Example_Simple_cn.md | 136 ----
docs/cn/FAQ.md | 110 ---
docs/cn/RocketMQ_Example.md | 8 +-
docs/cn/best_practice.md | 2 +-
docs/cn/design.md | 4 +-
docs/cn/image/rocketmq_architecture_1.png | Bin 62810 -> 89290 bytes
docs/cn/image/rocketmq_architecture_3.png | Bin 74884 -> 106758 bytes
docs/cn/msg_trace/user_guide.md | 19 +-
docs/cn/operation.md | 10 +-
docs/en/CLITools.md | 8 -
docs/en/Example_Transaction.md | 2 +-
docs/en/best_practice.md | 2 +-
.../client/java/API_Reference_DefaultMQProducer.md | 71 --
docs/en/image/rocketmq_architecture_1.png | Bin 62810 -> 89290 bytes
docs/en/image/rocketmq_architecture_3.png | Bin 74884 -> 106758 bytes
docs/en/msg_trace/user_guide.md | 16 -
docs/en/operation.md | 2 +-
.../rocketmq/example/benchmark/BatchProducer.java | 403 ----------
.../rocketmq/example/benchmark/Consumer.java | 66 +-
.../rocketmq/example/benchmark/Producer.java | 157 ++--
.../example/benchmark/TransactionProducer.java | 117 ++-
.../rocketmq/example/quickstart/Producer.java | 33 -
.../rocketmq/example/simple/PullConsumer.java | 154 ++--
.../filter/expression/UnaryExpression.java | 16 +-
.../rocketmq/filter/parser/ParseException.java | 7 +-
.../rocketmq/filter/parser/TokenMgrError.java | 3 +-
.../org/apache/rocketmq/filter/ParserTest.java | 2 +-
.../namesrv/processor/DefaultRequestProcessor.java | 26 +-
.../namesrv/routeinfo/RouteInfoManager.java | 43 +-
.../namesrv/routeinfo/RouteInfoManagerTest.java | 52 +-
pom.xml | 2 +-
.../rocketmq/remoting/common/RemotingHelper.java | 2 +-
.../rocketmq/remoting/netty/NettyClientConfig.java | 8 +-
.../rocketmq/remoting/netty/NettyLogger.java | 46 --
.../remoting/netty/NettyRemotingAbstract.java | 7 +-
.../rocketmq/remoting/netty/NettySystemConfig.java | 16 -
.../remoting/netty/NettyClientConfigTest.java | 64 --
.../rocketmq/store/AppendMessageCallback.java | 5 +-
.../apache/rocketmq/store/AppendMessageResult.java | 17 -
.../java/org/apache/rocketmq/store/CommitLog.java | 835 +++++++++++++--------
.../apache/rocketmq/store/DefaultMessageStore.java | 73 +-
.../java/org/apache/rocketmq/store/MappedFile.java | 26 +-
.../rocketmq/store/MessageExtBrokerInner.java | 12 -
.../org/apache/rocketmq/store/MessageStore.java | 4 +-
.../rocketmq/store/SelectMappedBufferResult.java | 7 +
.../apache/rocketmq/store/StoreStatsService.java | 109 ++-
.../rocketmq/store/config/MessageStoreConfig.java | 7 +-
.../rocketmq/store/dledger/DLedgerCommitLog.java | 250 +++++-
.../org/apache/rocketmq/store/ha/HAService.java | 63 +-
.../apache/rocketmq/store/ha/WaitNotifyObject.java | 64 +-
.../store/schedule/ScheduleMessageService.java | 5 -
.../apache/rocketmq/store/stats/BrokerStats.java | 4 +-
.../rocketmq/store/stats/BrokerStatsManager.java | 50 +-
.../apache/rocketmq/store/AppendCallbackTest.java | 28 +-
.../apache/rocketmq/store/BatchPutMessageTest.java | 18 +-
.../rocketmq/store/StoreStatsServiceTest.java | 18 +-
.../store/schedule/ScheduleMessageServiceTest.java | 6 +-
.../test/java/stats/BrokerStatsManagerTest.java | 47 --
.../rocketmq/tools/admin/DefaultMQAdminExt.java | 8 +-
.../tools/admin/DefaultMQAdminExtImpl.java | 12 +-
.../apache/rocketmq/tools/admin/MQAdminExt.java | 5 +-
.../rocketmq/tools/command/MQAdminStartup.java | 4 -
.../command/acl/DeleteAccessConfigSubCommand.java | 14 +-
.../command/acl/UpdateAccessConfigSubCommand.java | 8 +-
.../acl/UpdateGlobalWhiteAddrSubCommand.java | 6 +-
.../consumer/GetConsumerConfigSubCommand.java | 146 ----
.../message/QueryMsgByUniqueKeySubCommand.java | 5 +-
.../tools/command/message/SendMessageCommand.java | 17 +-
.../command/namesrv/AddWritePermSubCommand.java | 80 --
.../command/namesrv/WipeWritePermSubCommand.java | 2 +-
.../tools/admin/DefaultMQAdminExtTest.java | 7 -
.../consumer/GetConsumerConfigSubCommandTest.java | 83 --
.../namesrv/AddWritePermSubCommandTest.java | 37 -
142 files changed, 1593 insertions(+), 4064 deletions(-)
delete mode 100644 .github/workflows/greetings.yml
delete mode 100644
broker/src/test/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessorTest.java
delete mode 100644
common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/AddWritePermOfBrokerRequestHeader.java
delete mode 100644
common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/AddWritePermOfBrokerResponseHeader.java
delete mode 100644 distribution/benchmark/batchproducer.sh
delete mode 100644 docs/cn/Configuration_System.md
delete mode 100644 docs/cn/Deployment.md
delete mode 100644 docs/cn/Example_Batch.md
delete mode 100644 docs/cn/Example_Delay.md
delete mode 100644 docs/cn/Example_Simple_cn.md
delete mode 100644 docs/cn/FAQ.md
delete mode 100644 docs/en/client/java/API_Reference_DefaultMQProducer.md
delete mode 100644
example/src/main/java/org/apache/rocketmq/example/benchmark/BatchProducer.java
delete mode 100644
remoting/src/test/java/org/apache/rocketmq/remoting/netty/NettyClientConfigTest.java
delete mode 100644
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java
delete mode 100644
tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/AddWritePermSubCommand.java
delete mode 100644
tools/src/test/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommandTest.java
delete mode 100644
tools/src/test/java/org/apache/rocketmq/tools/command/namesrv/AddWritePermSubCommandTest.java