public interface MQAdminExt extends MQAdmin
| 限定符和类型 | 方法和说明 |
|---|---|
void |
createAndUpdateKvConfig(String namespace,
String key,
String value)
在 namespace 上添加或者更新 KV 配置
|
void |
createAndUpdateSubscriptionGroupConfig(String addr,
com.alibaba.rocketmq.common.subscription.SubscriptionGroupConfig config)
向指定Broker创建或者更新订阅组配置
|
void |
createAndUpdateTopicConfig(String addr,
com.alibaba.rocketmq.common.TopicConfig config)
向指定Broker创建或者更新Topic配置
|
void |
deleteIpsByProjectGroup(String key)
删除 project group 对应的所有 server ip
|
void |
deleteKvConfig(String namespace,
String key)
删除 namespace 上的 KV 配置
|
void |
deleteSubscriptionGroup(String addr,
String groupName)
删除 broker 上的 subscription group 信息
|
void |
deleteTopicInBroker(Set<String> addrs,
String topic)
删除 broker 上的 topic 信息
|
void |
deleteTopicInNameServer(Set<String> addrs,
String topic)
删除 broker 上的 topic 信息
|
com.alibaba.rocketmq.common.protocol.body.ClusterInfo |
examineBrokerClusterInfo()
查看集群信息
|
com.alibaba.rocketmq.common.protocol.body.ConsumerConnection |
examineConsumerConnectionInfo(String consumerGroup)
查看Consumer网络连接、订阅关系
|
com.alibaba.rocketmq.common.admin.ConsumeStats |
examineConsumeStats(String consumerGroup)
查询消费进度
|
com.alibaba.rocketmq.common.protocol.body.ProducerConnection |
examineProducerConnectionInfo(String producerGroup,
String topic)
查看Producer网络连接
|
com.alibaba.rocketmq.common.subscription.SubscriptionGroupConfig |
examineSubscriptionGroupConfig(String addr,
String group)
查询指定Broker的订阅组配置
|
com.alibaba.rocketmq.common.TopicConfig |
examineTopicConfig(String addr,
String topic)
查询指定Broker的Topic配置
|
com.alibaba.rocketmq.common.protocol.route.TopicRouteData |
examineTopicRouteInfo(String topic)
查看Topic路由信息
|
com.alibaba.rocketmq.common.admin.TopicStatsTable |
examineTopicStats(String topic)
查询Topic Offset信息
|
com.alibaba.rocketmq.common.protocol.body.TopicList |
fetchAllTopicList()
从Name Server获取所有Topic列表
|
com.alibaba.rocketmq.common.protocol.body.KVTable |
fetchBrokerRuntimeStats(String brokerAddr)
获取Broker运行时数据
|
String |
getIpsByProjectGroup(String projectGroup)
通过 project 获取所有的 server ip 信息
|
String |
getKVConfig(String namespace,
String key)
从Name Server获取一个配置项
|
com.alibaba.rocketmq.common.protocol.body.KVTable |
getKVListByNamespace(String namespace)
获取指定Namespace下的所有kv
|
List<String> |
getNameServerAddressList()
获取Name Server地址列表
|
String |
getProjectGroupByIp(String ip)
通过 server ip 获取 project 信息
|
void |
putKVConfig(String namespace,
String key,
String value)
向Name Server增加一个配置项
|
List<com.alibaba.rocketmq.common.admin.RollbackStats> |
resetOffsetByTimestamp(String consumerGroup,
String topic,
long timestamp,
boolean force)
按照时间回溯消费进度
|
void |
shutdown() |
void |
start() |
void |
updateBrokerConfig(String brokerAddr,
Properties properties)
更新Broker配置
|
com.alibaba.rocketmq.common.protocol.body.ConsumeByWho |
whoConsumeTheMessage(String msgId)
查看某个订阅组被谁消费了
|
int |
wipeWritePermOfBroker(String namesrvAddr,
String brokerName)
清除某个Broker的写权限,针对所有Name Server
|
createTopic, earliestMsgStoreTime, maxOffset, minOffset, queryMessage, searchOffset, viewMessagevoid start()
throws MQClientException
void shutdown()
void updateBrokerConfig(String brokerAddr, Properties properties) throws com.alibaba.rocketmq.remoting.exception.RemotingConnectException, com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException, com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException, UnsupportedEncodingException, InterruptedException, MQBrokerException
brokerAddr - properties - MQBrokerExceptionInterruptedExceptionUnsupportedEncodingExceptioncom.alibaba.rocketmq.remoting.exception.RemotingTimeoutExceptioncom.alibaba.rocketmq.remoting.exception.RemotingSendRequestExceptioncom.alibaba.rocketmq.remoting.exception.RemotingConnectExceptionvoid createAndUpdateTopicConfig(String addr, com.alibaba.rocketmq.common.TopicConfig config) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
addr - config - MQClientExceptionInterruptedExceptionMQBrokerExceptioncom.alibaba.rocketmq.remoting.exception.RemotingExceptionvoid createAndUpdateSubscriptionGroupConfig(String addr, com.alibaba.rocketmq.common.subscription.SubscriptionGroupConfig config) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
addr - config - MQClientExceptionInterruptedExceptionMQBrokerExceptioncom.alibaba.rocketmq.remoting.exception.RemotingExceptioncom.alibaba.rocketmq.common.subscription.SubscriptionGroupConfig examineSubscriptionGroupConfig(String addr, String group)
addr - group - com.alibaba.rocketmq.common.TopicConfig examineTopicConfig(String addr, String topic)
addr - topic - com.alibaba.rocketmq.common.admin.TopicStatsTable examineTopicStats(String topic) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException, InterruptedException, MQBrokerException
topic - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQClientExceptionInterruptedExceptionMQBrokerExceptioncom.alibaba.rocketmq.common.protocol.body.TopicList fetchAllTopicList()
throws com.alibaba.rocketmq.remoting.exception.RemotingException,
MQClientException,
InterruptedException
InterruptedExceptionMQClientExceptioncom.alibaba.rocketmq.remoting.exception.RemotingExceptioncom.alibaba.rocketmq.common.protocol.body.KVTable fetchBrokerRuntimeStats(String brokerAddr) throws com.alibaba.rocketmq.remoting.exception.RemotingConnectException, com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException, com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException, InterruptedException, MQBrokerException
MQBrokerExceptionInterruptedExceptioncom.alibaba.rocketmq.remoting.exception.RemotingTimeoutExceptioncom.alibaba.rocketmq.remoting.exception.RemotingSendRequestExceptioncom.alibaba.rocketmq.remoting.exception.RemotingConnectExceptioncom.alibaba.rocketmq.common.admin.ConsumeStats examineConsumeStats(String consumerGroup) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException, InterruptedException, MQBrokerException
consumerGroup - InterruptedExceptionMQClientExceptioncom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptioncom.alibaba.rocketmq.common.protocol.body.ClusterInfo examineBrokerClusterInfo()
throws InterruptedException,
MQBrokerException,
com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException,
com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException,
com.alibaba.rocketmq.remoting.exception.RemotingConnectException
InterruptedExceptionMQBrokerExceptioncom.alibaba.rocketmq.remoting.exception.RemotingTimeoutExceptioncom.alibaba.rocketmq.remoting.exception.RemotingSendRequestExceptioncom.alibaba.rocketmq.remoting.exception.RemotingConnectExceptioncom.alibaba.rocketmq.common.protocol.route.TopicRouteData examineTopicRouteInfo(String topic) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException, InterruptedException
topic - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQClientExceptionInterruptedExceptioncom.alibaba.rocketmq.common.protocol.body.ConsumerConnection examineConsumerConnectionInfo(String consumerGroup) throws com.alibaba.rocketmq.remoting.exception.RemotingConnectException, com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException, com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException, InterruptedException, MQBrokerException, com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException
consumerGroup - MQBrokerExceptionInterruptedExceptioncom.alibaba.rocketmq.remoting.exception.RemotingTimeoutExceptioncom.alibaba.rocketmq.remoting.exception.RemotingSendRequestExceptioncom.alibaba.rocketmq.remoting.exception.RemotingConnectExceptionMQClientExceptioncom.alibaba.rocketmq.remoting.exception.RemotingExceptioncom.alibaba.rocketmq.common.protocol.body.ProducerConnection examineProducerConnectionInfo(String producerGroup, String topic) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException, InterruptedException, MQBrokerException
producerGroup - topic - InterruptedExceptionMQClientExceptioncom.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionint wipeWritePermOfBroker(String namesrvAddr, String brokerName) throws com.alibaba.rocketmq.remoting.exception.RemotingCommandException, com.alibaba.rocketmq.remoting.exception.RemotingConnectException, com.alibaba.rocketmq.remoting.exception.RemotingSendRequestException, com.alibaba.rocketmq.remoting.exception.RemotingTimeoutException, InterruptedException, MQClientException
brokerName - MQClientExceptionInterruptedExceptioncom.alibaba.rocketmq.remoting.exception.RemotingTimeoutExceptioncom.alibaba.rocketmq.remoting.exception.RemotingSendRequestExceptioncom.alibaba.rocketmq.remoting.exception.RemotingConnectExceptioncom.alibaba.rocketmq.remoting.exception.RemotingCommandExceptioncom.alibaba.rocketmq.common.protocol.body.ConsumeByWho whoConsumeTheMessage(String msgId)
msgId - void putKVConfig(String namespace, String key, String value)
namespace - key - value - String getKVConfig(String namespace, String key)
namespace - key - com.alibaba.rocketmq.common.protocol.body.KVTable getKVListByNamespace(String namespace) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQClientException, InterruptedException
namespace - InterruptedExceptionMQClientExceptioncom.alibaba.rocketmq.remoting.exception.RemotingExceptionvoid deleteTopicInBroker(Set<String> addrs, String topic) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
addrs - topic - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionvoid deleteTopicInNameServer(Set<String> addrs, String topic) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
addrs - topic - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionvoid deleteSubscriptionGroup(String addr, String groupName) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
addr - groupName - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionvoid createAndUpdateKvConfig(String namespace, String key, String value) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
namespace - key - value - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionvoid deleteKvConfig(String namespace, String key) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
namespace - key - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionString getProjectGroupByIp(String ip) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
ip - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionString getIpsByProjectGroup(String projectGroup) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
projectGroup - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionvoid deleteIpsByProjectGroup(String key) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
key - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionList<com.alibaba.rocketmq.common.admin.RollbackStats> resetOffsetByTimestamp(String consumerGroup, String topic, long timestamp, boolean force) throws com.alibaba.rocketmq.remoting.exception.RemotingException, MQBrokerException, InterruptedException, MQClientException
consumerGroup - topic - timestamp - force - com.alibaba.rocketmq.remoting.exception.RemotingExceptionMQBrokerExceptionInterruptedExceptionMQClientExceptionCopyright © 2012–2013. All rights reserved.