Commit Graph
73 Commits
Author SHA1 Message Date
ph3636andph3636 4117d0019a [ISSUE 2800] optimize: the spelling of topicSynFlag
Co-authored-by: ph3636 <tianxingguang@kanzhun.com>
2021-04-14 16:35:21 +08:00
panzhi 4645942680 [ISSUE #2748] Fix deleteSubscriptionGroup not remove consumer offset 2021-03-24 11:39:12 +08:00
william.zandzhuweilin 0d8a184ad1 [ISSUE #2670]Hide Client IP when there's no -s true in command ConsumerProgress
Co-authored-by: zhuweilin <zhuweilin@iie.ac.cn>
2021-02-14 20:44:48 +08:00
zhangjidi2016andzhangjidi2016 a460c5c102 [ISSUE #1770] Add a query message trace command in mqadmin. (#2303)
Co-authored-by: zhangjidi2016 <zhangjidi@cmss.chinamobile.com>
2020-09-17 13:57:01 +08:00
Chengyang Heandhechengyang 8c71dee631 [ISSUE #2162] Fix getBrokerConfig help info wrong description (#2163)
Co-authored-by: hechengyang <hechengyang@cmss.chinamobile.com>
2020-07-23 12:29:00 +08:00
Jun b6307dfce1 [ISSUE #1976]System topic should add permission checking globally (#1985)
* fix #1976
System Topic like SCHEDULE_TOPIC_XXXX should not be create or delete by user

* User can not send message to system topic SCHEDULE_TOPIC_XXXX

* the-->The

* fix magic number 18

* move system topic to TopicValidator except TBW102

* move TBW102 and isSystemTopic to TopicValidator

* add test code

* validateTopic --> validatorSystemTopic, validatorBlacklistTopic

* validateTopic --> validatorSystemTopic, validatorBlacklistTopic

* rename some methods
2020-06-05 18:28:56 +08:00
von gosling f7c21db6fc Merge pull request #1629 from martianzhang/master
[ISSUE #1620]fix #1620 amout spell error
2020-01-03 16:18:17 +08:00
LiosWong 691e374f00 fix typo:paramter 2020-01-01 21:40:23 +08:00
Leon Zhang 8e2ce06b53 fix #1620 amout spell error
mqadmin tools with command clusterRT/checkMsgSendRT, there are
  spell error for message amount in long format option type.
2019-11-29 22:52:15 +08:00
Heng Du c0a2735f9b Merge pull request #1430 from zongtanghu/update_topic_perm_failed
[ISSUE #1429]Update Broker's Topic Read or Write Perm failed.
2019-10-14 11:23:53 +08:00
huzongtang 60d02121f0 polish codes for updateTopicPermSubCommand. 2019-10-14 10:56:59 +08:00
zhangjidi a3954b4572 GetAccessConfigSubCommand for ACL configuration (#1263) 2019-09-29 16:45:33 +08:00
yuanjunhui fb7a7e5949 [ISSUE #1483] fix bug in QueryMsgByIdSubCommand print OffsetID twice 2019-09-25 17:35:55 +08:00
huzongtang db77463b6e [ISSUE#1429]Update Broker's Topic Read or Write Perm failed. 2019-08-29 16:50:25 +08:00
King 74ffae6dc2 [ISSUE 504] Polish 'No route info of this topic' exception (#1415)
* Polish 'no route info of this topic' exception.

* Write exception to log

* Modify logic that cannot connect to nameserver

* Solve the problem that the regression test does not pass.

* Adapt to lite pull consumer

* Make checkNameServerSetting function private and change its name.
2019-08-28 11:11:56 +08:00
程向往 d66243c03c [ISSUE #598] Enhance transaction by putting messages that exceed max check times to system topic (#633)
* add logic of putting message that exceeds max-check-times to system topic TRANS_CHECK_MAXTIME_TOPIC

* add test case:testResolveDiscardMsg

* add @After logic to test case

* comment brokerController.shutdown and use mock

* add logic of resuming half message check

* add test case:resumeCheckHalfMessage

* delete commented codes
2019-06-19 09:04:29 +08:00
Hu Zongtang a2165d8051 [ISSUE #1156]new mqadmin API for ACL configuration (#1217)
* [issue#1164]return the codes to original reput method part.

* [issue#1164]fix issue that Consumer Instance can't consume message from slave when cluster is in the high level tps and master has been killed.

* [issue#1164]if the broker is a master node,then modify reputFromOffset correctly.

* [issue#1164]add some coding comments.

* [ISSUE#1156]new mqadmin API for ACL configuration.Add dataVersion and write data to acl yaml config file in the acl module.

* [ISSUE#1156]add unit test cases for new acl mqadmin API command which adding dataversion part.

* [ISSUE#1156]implement update,delete and query Acl config version in new acl mqadmin API command.

* [ISSUE#1156]polish and optimize the implementation for new acl mqadmin API command.

* [ISSUE#1156]fix the issues that topicPerms and groupPerms can't be updated and there is NPE when querying acl config version.

* [ISSUE#1156]fix small issue that specify wrong plainAccessConfig attribute,the correct one is AccessKey.

* [ISSUE#1156]add updateGlobalWhiteAddr subcommand codes for mqadmin acl command.

* [ISSUE#1156]adjust some codes for cluster acl config version list in the mqadmin acl commands.

* [ISSUE#1156]add acl mqadmin command part in the acl user_guide docs.

* [ISSUE#1156]polish and optimize some part of acl mqadmin command codes.

* [ISSUE#1156]fix code comments issue that the first letter needs to be capitalized and adjust the contents of acl user_guide.
2019-06-14 12:22:10 +08:00
hdchen 8c59640d6e [RIP-10] modify test case of BrokerConsumeStatusSubCommand (#983) 2019-05-14 16:53:06 +08:00
蔡盛智 26878e9c79 [RIP-10] Add test cases for QueryMsgByUniqueKeySubCommand (#945) 2019-05-14 16:51:13 +08:00
Hu Zongtang 929c76c62b [ISSUE #1147]Broker will report Exception if open the aclEnable and enableDLegerCommitLog flag at the same time. (#1149)
* [issue#1078]fix User can't use mqadmin command normally if they don't copy the tool.yml file to their related fold and AclEnable flag is closed.

* [issue#1147]Broker will report Exception if open the aclEnable and enableDLegerCommitLog flag at the same time.

* [issue#1147]Broker will report Exception if open the aclEnable and enableDLegerCommitLog flag at the same time.

* [issue#1147]Add the restriction of Acl in the acl's user guide.

* [issue#1147]Adjust some codes for acl issue that users can't open the aclEnable and use Master/Slave or Dledger the same time.

* [issue#1147]Adjust and optimize some codes for acl issue that users can't open the aclEnable and use Master/Slave or Dledger the same time.

* [issue#1147]return back for original codes for acl issue that users can't open the aclEnable and use Master/Slave or Dledger the same time.
2019-04-27 10:29:37 +08:00
Hu Zongtang 29438a11c1 [ISSUE #1078]fix User can't use mqadmin command normally if they don't copy the tool.yml file to related fold and AclEnable flag is closed. (#1079)
* [issue#1078]fix User can't use mqadmin command normally if they don't copy the tool.yml file to their related fold and AclEnable flag is closed.
2019-04-10 10:03:34 +08:00
dalaoyang ef9c806786 [RIP-10] Add test cases for UpdateKvConfigCommand (#929)
[RIP-10] Add test cases for UpdateKvConfigCommand
2019-02-27 19:54:41 +08:00
husterxsp d2fba24cab [ISSUE #776] make mqadmin usage information more friendly to user(#796) 2019-02-21 17:26:46 +08:00
Hu Zongtang 691b712167 [ISSUE#662]capitalizing the first letter in comments and removing the unless comments for acl and msg trace feature codes. (#669)
* [ISSUE#662]capitalizing the first letter in comments and removing the  unless comments for acl and msg trace feature codes.

* [ISSUE#662]polish the acl feature codes.
2019-01-07 19:03:54 +08:00
dongeforever 1a80c5ba57 Trivial pilishment for acl and msg_trace 2018-12-29 12:03:40 +08:00
dongeforever 4250af6e56 Merge branch 'feature_acl' into msg_track 2018-12-26 21:23:26 +08:00
wangshaojie4039 459b246d28 [ISSUE#403] fix some bugs and Optimization code for rocketmq's acl feature. (#632)
* [ISSUE#403] fix some bugs and Optimization code for rocketmq's acl feature. 

* [ISSUE#403] fix some bugs and Optimization code for rocketmq's acl feature. 

* Update MQAdminStartup.java

* Update MQAdminStartup.java
2018-12-26 18:51:23 +08:00
huzongtang cde6f40441 [ISSUE #525] Support the message track,these committed codes have supported trace_topic name value Configurable by users. 2018-12-11 16:03:53 +08:00
Zhendong Liu c50ada6ef1 Merge pull request #597 from zongtanghu/develop
[ISSUE #525] Support the message track. Merge to branch msg_track
2018-12-10 17:00:21 +08:00
maowei.ymw 7fd657f75c Format the precision output TPS 2018-12-10 13:39:24 +08:00
huzongtang 47556d6a36 I have already fix my code as suggestion.Please help to review them.[ISSUE #525]. 2018-11-28 10:50:55 +08:00
hujie fb60683850 admin 2018-11-27 10:04:16 +08:00
hujie 81c71c2185 admin 2018-11-26 18:48:57 +08:00
hujie 5503cff59c tools acl 2018-11-23 18:56:40 +08:00
hujie ceaa64bb56 tools acl 2018-11-23 18:26:54 +08:00
huzongtang e04db85e66 I have finished developing the new feature for the message track #525 initially. 2018-11-14 00:16:40 +08:00
ymwneu 60efa68f3b Fix NPE when getting the localhost using admin tool (#518) 2018-11-02 15:39:50 +08:00
射声 5898399127 Modify commandLine getOption 2018-08-31 16:13:16 +08:00
dongeforever 2b692c912d Merge branch 'develop' 2018-08-01 14:41:07 +08:00
XiaoZYang ba91ec8a7e FIX admin subcommand consumeMessage can pull message with timestamp greater then now (#380) 2018-07-23 23:09:26 +08:00
XiaoZYang 3f7dda3c0c [ISSUE #377] FIX Admin subcommand consumeMessage should quit when catching an exception (#378) 2018-07-23 19:50:51 +08:00
Jaskey fc54c2ada7 ROCKETMQ-223-Rename DEFAULT_TOPIC (#119) 2018-07-14 10:46:44 +08:00
what-a-good-jungle b75af6b0c2 [ROCKETMQ-353] Add sendMessageCommand and consumeMessageCommand (#332) 2018-07-14 09:55:59 +08:00
Li Zhanhui 2047f94d81 [BugFix] When deleting topics, instruct both master and slave nodes to delete it such that consume queues are all deleted 2018-05-28 16:38:13 +08:00
Li Zhanhui c264de9c93 Format output 2018-05-23 14:20:46 +08:00
Li Zhanhui 0499586eb0 Show client IP only when required 2018-05-23 14:20:38 +08:00
lonsonlee 117d690e50 Modify Project Tools : remove duplicates initCommand and missing tag ")" (#269)
Minor fix for command tool, remove duplicates initCommand and missing tag ")"
2018-04-27 11:12:27 +08:00
lindzh 46f91479d9 [ROCKETMQ-359] Replace slf4j api used in RocketMQ with InternalLogger (#221) 2018-03-07 14:29:09 +08:00
lindzh cc0b3d0918 [ROCKETMQ-336] Wrong format System.out.printf used in mqadmin (#208) 2017-12-20 15:48:33 +08:00
lindzh 8c30310483 [ROCKETMQ-292] Delete system.exit in MQAdminStartup
Author: lindzh <linsony0@163.com>

Closes #169 from lindzh/fix_main_system.exit.
2017-12-01 20:00:18 +08:00