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.
from 48d3c7e [maven-release-plugin] prepare for next development iteration
add a027f8d [maven-release-plugin] prepare release rocketmq-all-4.9.0
add a1babab [maven-release-plugin] prepare for next development iteration
add f42db53 Changing the comma input method
add 317fd7e Changing the comma input method
add 52348b8 Merge pull request #2977 from ferris-cx/master
add 2fe6dc3 #2990 Add message tracing switch in sendMessage command of
mqadmin
add 57c166b Merge pull request #2991 from yuz10/develop4
add b9c108b Merge remote-tracking branch
'origin/develop_include_3_commits' into develop
add 93dd086 AsyncTraceDispatcher unique groupName
add 0c36d14 remove SubAfter field
add a92996a Merge pull request #3005 from lfz757077613/develop
add 5fe0041 Change default value of some parameters:
sendMessageThreadPoolNums/useReentrantLockWhenPutMessage/flushCommitLogTimed/endTransactionThreadPoolNums
add e5a3f7d Merge pull request #2888 from areyouok/dev_speed_D
add e126310 [ISSUE #2997] Add a Chinese version of Configuration_System.md
add 2b236c3 [ISSUE 3019] Fixed bug with batch-sent message statistics
add 160c577 test(benchmark): support delay message test (#3010)
add a0a2192 [ISSUE #2873] add benchmark for batch message
add 6b519ef [ISSUE #3068] remove jaeger tracing dependency in release
package
add a2f8810 [ISSUE #2988] fix fail to send trace of last message before
shutting down producer
add fcc20de [ISSUE #3059] typo transactional message wiki
add 95a6275 typo
add df35edf Merge pull request #3088 from sunbufu/fix-a-typo
add 9a5ec90 [ISSUE #3109]Return a no-support value when not match any
request code
add 56c3ad8 update the option's description of deleteAccessConfig command
add 22647de update the option's description of updateAccessConfig command
add b186bcd update the option's description of consumer.sh
add 4f33895 Merge branch 'develop' into RocketMQ-zhurunhua
add 2a63717 Merge pull request #2882 from zhurunhua/RocketMQ-zhurunhua
add 6591589 [ISSUE #3118] Fix type conversion exception
add 7c36468 [ISSUE #3089] fix Print log format is incorrect in
NettyRemotingAbstract class (#3126)
add 6cee569 duplicate doAfterRpcHooks
add 7029545 Merge branch 'apache:develop' into develop
add b74c48b add trace data format test case
add cba3e05 Merge pull request #3124 from lizhiboo/add_trace_test_case
add d65778f [ISSUE #2883] [Part B] Improve produce performance in M/S
mode. (#2885)
add 3183122 Eliminate array copy (#2886)
add 7f1cb79 remove useless code
add 2fc1148 Merge pull request #3111 from codersfarm/develop
add 589e87c [ISSUE #3099] Fix the incorrect judegment 'writePos -
lastCommittedPosition > commitLeastPages' in the method 'commit0' of class
'MappedFile' (#3125)
add f4b3d4f fix namesrv endpoint
add 3efcd85 Merge pull request #3122 from panzhi33/master
add 94e0899 [ISSUE #3097] docs remove obsolete/error configuration
add 2bd0676 Merge pull request #3116 from trdmm/develop
add d8dec65 add different send examples
add d0d2f15 add chinese version of FAQ.md
add e1f94aa Merge pull request #3034 from PatrickkZ/develop
add 278d328 add Chinese version
add 0cc5ad2 add Chinese version of Example_Batch
add 69e8185 Merge pull request #3036 from Cu-Cu/master
add 622bbbf add some doc of the API_Reference_DefaultMQProducer of
English.
add 5908ca7 Merge pull request #3056 from zplovekq/doc_add
add 23f3893 Add a Chinese version of Deployment.md
add 30058cf Merge pull request #3038 from IntroDrop/develop
add 92f2d03 log exception stack
add 83efcce Merge remote-tracking branch 'upstream/develop' into
fix-issue-603
add bc73c32 use String.format() in warn log.
add 89d9ed7 Merge pull request #3100 from sunbufu/fix-issue-603
add a99cf37 Add Chinses Version Doc of Example_Simple.md
add e4daba5 Merge pull request #3042 from haoran-pku/master
add 17a8e93 fix spell error
add cf0819e Merge pull request #3144 from A-Zee029/master
add 44e2669 [ISSUE #3128] fix the delete global white addresses
add 4c1998a retrigger ci
add a315833 Merge pull request #3132 from
zhangjidi2016/fix_update_globalWhiteAddresses
add 04c7354 delete the unuse code
add 36333ce Merge pull request #3157 from yglovewms/yeyi
add 61cd395 code style(client):polish lite pull consumer code style
add 893e8fd code style(client):polish lite pull consumer code style
add 6aabf77 Merge pull request #3047 from qingjiyuji/develop
add 18e2a26 [ISSUE #3164]Fix the checkstyle error
add bb9a70c Merge pull request #3165 from
zhangjidi2016/fix_checkstyle_error
add d7c2d25 [ISSUE #2708] fix offset rollback when fetch offset from
broker exception
add 5b945a9 Merge pull request #3158 from
Zanglei06/fix_rmq_client_offset_dev
add 5808772 fix checkstyle fail
add df88bce add msgTraceEnable config in transaction producer benchmark
add 011035f Merge pull request #3163 from yuz10/develop6
add ece364a Improve the comment of maxReconsumeTimes
add 35a15b6 Merge pull request #3022 from heihaozi/maxReconsumeTimes
add 25f6711 [statistics] Fix the inconsistency of
putMessageDistributeTime statistics
add 765cac3 Merge pull request #3025 from Git-Yang/statistics_bug
add bc3eeed fix: fix issue 2055
add 74aa3e0 Update SendMessageProcessor.java
add c63ec20 Merge pull request #2058 from RealBar/fix/issue2055
add 40e1435 #2990 Add document
add 1e982af Merge pull request #2995 from yuz10/develop4
add 361eb8d Upgrade netty-all dependency version to 4.1.65.Final
add 9a9039e Merge pull request #3032 from messense/upgrade-netty-all
add b954d35 feat: issue2715, make netty parameter configure by system
property
add 33a533b feat: add some test case
add 03adb63 feat: add some test case
add 98237b1 feat: add some test case
add 67ceb64 fix: add license
add 59cbbc4 feat: add some test case
add d60643a Merge pull request #2720 from EZLippi/feature/issue2715
add 36422c5 [ISSUE #3066]producing a ghost consumer
add d93dc4d Merge branch 'apache:develop' into develop
add 4e5a60c [ISSUE #2442] when happening system busy, retry
add 062e6f3 revert [ISSUE #2442] when happening system busy, retry
add c75ef50 Merge branch 'apache:develop' into develop
add 8eb275f Merge branch 'apache:develop' into develop
add 36e6687 Merge pull request #3120 from lwclover/develop
add 360b616 [ISSUE #3185]remove the arm machine test in travis ci
add 0325772 [ISSUE #2883] [Part E] Improve produce performance in M/S
mode. (#2889)
add b68724b [ISSUE #3030]Remove the -Xmn JVM parameter when using G1
(#3170)
add 800421e registerProducer & unregisterProducer add synchronization
too, how about add for producer
add 72128f7 Merge branch 'develop' of
https://github.com/lwclover/rocketmq-2.git into develop
add 6f7b0d6 Merge pull request #3182 from lwclover/develop
add 17b9efe [ISSUE #3177]updateAclConfig in all brokers. (#3184)
add 1b757b4 [ISSUE #3196] Check if "requestHeader" is null before
"requestHeader.getTopic()"
add 1eaa38f [ISSUE #3200] Fix code style in 'NettySystemConfig.java'
add d067bfc [ISSUE #3192] Make free disk value more accurate
add 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.
add a23df96 [ISSUE 2883] Improve performance of
string2messageProperties/messageProperties2String, and save 1 byte for each
message.
add 2509b0e Merge pull request #2961 from areyouok/dev_speed_F
add b13a4c8 [ISSUE 2883] [Part G] Optimise parse performance for
SendMessageRequestHeaderV2
add a137e48 [ISSUE 2883] [Part G] Optimise parse performance for
SendMessageRequestHeaderV2, unit test
add 3e01424 Merge pull request #3134 from areyouok/dev_speed_G
add 94abced [ISSUE #3199] Two timed task for RequestFutureTable (#3202)
add 66eeaed #3175 check acl config before update. otherwise broker may
fail to start
add 3aa4943 fix checkstyle
add d21266d Merge branch 'develop' into develop3
add 9e8fea9 Merge pull request #3176 from yuz10/develop3
add 5e58893 prepare to release rocketmq 4.9.1 version
add 73db297 [#Issue3205]Fix the issue of code style in client and broker
modules.
add ec985ee Merge pull request #3206 from
zongtanghu/develop_fix_4.9.1_codestyle
add a1bfe1a [maven-release-plugin] prepare release rocketmq-all-4.9.1
add a7e71cb [maven-release-plugin] prepare for next development iteration
add 2820e47 [ISSUE #3215] polish litePullConsumer seek logic #3216
add 5bd7ccc Add little rocketmq robot
add d1f9915 Place into workflows directory
add 15b0cde Update greetings.yml
add 5a2aa7e Update greetings.yml
add d83b7e5 Fix typo
add cfadd4d Update greetings.yml
add 39f549a Update greetings.yml
add a20f31b Limit event trigger
add fb8bc64 Merge branch 'develop'
add e9c4253 [maven-release-plugin] prepare release rocketmq-all-4.9.1
add bb34171 [maven-release-plugin] prepare for next development iteration
add 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
add 0fdc73d Merge pull request #3033 from
zyh-future/zyh_asuncproducer_doc_fix
add 3a2b172 [ISSUE #3006]Replace ScheduledExecutorService instead of
Timer to avoid affecting other tasks during exception (#3001)
add 44bdeed [ISSUE 3203] Replace the class 'StringBuffer' by
'StringBuilder' (#3204)
add 9e66da4 Merge branch 'develop_include_prs_after_4.9.1_version',
remote-tracking branch 'origin' into develop
add 7c7e9ac [ISSUE #3284]Optimizing benchmark code (#3285)
add 2cac866 [ISSUE #3136] TraceDataEncoder add SubAfter trace bean
timestamp (#3137)
add 857d28d [ISSUE #3284]Optimizing benchmark code (#3317)
add d7a830c [ISSUE 3194] [PART A] Use LongAdder instead of AtomicLong in
BrokerStatsService to improve performance. (#3195)
add fea769d [ISSUE #3284]Optimize the buildMessage method (#3324)
add 7519a53 [ISSUE 3333] Remove commons-codes dependency (#3334)
add ef7685d [ISSUE #3341](doc)fix typo in update operation.md
add b2aa85d [ISSUS #3340] (doc)add hyperlink for client repos in the
introduction. (#3338)
add 4b7a90a [#3326] fix send trace fail if useTLS=true (#3325)
add 8434658 [ISSUE #2724] Resend message to DLQ directly when max
reconsume times reach (#3318)
add 564ee29 [ISSUE] Add get stats and single queue stats for schedule
topic
add 3604100 [ISSUE #3314] Make mqClientApi request timeout settable
add 53c55f7 [ISSUE #3245] Use df algorithm to calculate the disk used
ratio
add 83b04d0 [ISSUE #3346]Avoid double parse remoteAddr in rpcHook call
add bf343a3 [ISSUE #3225]change Random to ThreadLocalRandom in broker
add 8d964f4 close #1848
add 1f2b84b fix #1883 fix wipeWritePerm doc desc
add f9a0f53 Merge pull request #1858 from coder-zzzz/github_features/#1848
add 147d23e [ISSUE #3281 ][acl] fix fail to delete topic perm list and
global white address(#3128) (#3280)
add 311d76f [ISSUE 3194] [PART C] Replace AtomicLong with LongAdder in
StatsItem.java to improve performance (#3351)
add 0a16ff6 DLQ topic default perm change
add b822db0 Fix DLQ can't be query sometimes
add 502ca60 fix ci
add a9ae546 Merge pull request #2437 from maixiaohai/DLQ_perm
add 0de4038 [ISSUE #3361]DefaultMQProducer's constructor can call the
overloaded constructor. (#3362)
add 0363be1 add response code for retrying
add d6da221 fix import issue
add 67ccb7f Merge pull request #2729 from wz2cool/master
add 46bd4be [ISSUE #2964] Add a query consumer config command in mqadmin.
add a9837d9 Merge pull request #2965 from
zhangjidi2016/add_getConsumerConfig_command
add ced5843 Update rocketmq client maven version
add ee55441 Merge pull request #3335 from zhouwentong1993/patch-1
add 2baae14 Improve performance of expandIP, and readable
add 7a6c374 Revert "Improve performance of expandIP, and readable"
add 6358b3c Revert "Improve performance of expandIP, and readable"
add 97da4ac Improve performance of expandIP, and readable
add 7314183 netadress toUpperCase beforehand
add 0748aa0 Merge pull request #3322 from 844392610/develop_xm
add 67f4357 add checkstyle to travis ci
add 401dc8e production level pull api demo
add 1e8e728 Merge pull request #3295 from lwclover/develop
new 2bf133b Merge branch 'develop' into 5.0.0-preview
new dd09ba1 merger from develop branch and fix compile error
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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 +
...java => AddWritePermOfBrokerRequestHeader.java} | 2 +-
...ava => AddWritePermOfBrokerResponseHeader.java} | 13 +-
.../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 +-
.../benchmark/{consumer.sh => batchproducer.sh} | 2 +-
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/{en => cn}/Example_Batch.md | 15 +-
docs/{en => cn}/Example_Delay.md | 16 +-
.../Example_Simple.md => cn/Example_Simple_cn.md} | 24 +-
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 89290 -> 62810 bytes
docs/cn/image/rocketmq_architecture_3.png | Bin 106758 -> 74884 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 89290 -> 62810 bytes
docs/en/image/rocketmq_architecture_3.png | Bin 106758 -> 74884 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 +-
...SubCommand.java => AddWritePermSubCommand.java} | 29 +-
.../command/namesrv/WipeWritePermSubCommand.java | 2 +-
.../tools/admin/DefaultMQAdminExtTest.java | 7 +
.../GetConsumerConfigSubCommandTest.java} | 11 +-
.../AddWritePermSubCommandTest.java} | 19 +-
142 files changed, 3531 insertions(+), 1659 deletions(-)
create mode 100644 .github/workflows/greetings.yml
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessorTest.java
copy
common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/{WipeWritePermOfBrokerRequestHeader.java
=> AddWritePermOfBrokerRequestHeader.java} (94%)
copy
common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/{WipeWritePermOfBrokerRequestHeader.java
=> AddWritePermOfBrokerResponseHeader.java} (81%)
copy distribution/benchmark/{consumer.sh => batchproducer.sh} (91%)
create mode 100644 docs/cn/Configuration_System.md
create mode 100644 docs/cn/Deployment.md
copy docs/{en => cn}/Example_Batch.md (79%)
copy docs/{en => cn}/Example_Delay.md (76%)
copy docs/{en/Example_Simple.md => cn/Example_Simple_cn.md} (82%)
create mode 100644 docs/cn/FAQ.md
create mode 100644 docs/en/client/java/API_Reference_DefaultMQProducer.md
create mode 100644
example/src/main/java/org/apache/rocketmq/example/benchmark/BatchProducer.java
create mode 100644
remoting/src/test/java/org/apache/rocketmq/remoting/netty/NettyClientConfigTest.java
create mode 100644
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java
copy
tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/{WipeWritePermSubCommand.java
=> AddWritePermSubCommand.java} (77%)
copy
tools/src/test/java/org/apache/rocketmq/tools/command/{broker/UpdateBrokerConfigSubCommandTest.java
=> consumer/GetConsumerConfigSubCommandTest.java} (92%)
copy
tools/src/test/java/org/apache/rocketmq/tools/command/{acl/GetAccessConfigSubCommandTest.java
=> namesrv/AddWritePermSubCommandTest.java} (68%)
