-
查询消费列表或详情 - 分布式消息服务RocketMQ版
brokers Array of Brokers objects Topic关联代理(当查询Topic消费“详情”才显示此参数)。 表4 Brokers 参数 参数类型 描述 broker_name String Topic关联代理名称。
-
RocketMQ相关概念 - 分布式消息服务RocketMQ版
生产者/消费者在生产/消费消息前,需要先从NameServer获取元数据。
-
修改实例信息 - 分布式消息服务RocketMQ版
" nameUpdateInstanceReq:= "rocketmq001" request.Body = &model.UpdateInstanceReq{ Description: &descriptionUpdateInstanceReq, Name: &nameUpdateInstanceReq
-
发送定时消息 - 分布式消息服务RocketMQ版
final ClientServiceProvider provider = ClientServiceProvider.loadService(); String topic = "yourDelayTopic"; // 填入grpc连接地址/grpc
-
导出死信消息 - 分布式消息服务RocketMQ版
store_timestamp Number 存储消息的时间。 born_timestamp Number 产生消息的时间。 reconsume_times Integer 重试次数。 body String 消息体。 body_crc Number 消息体校验和。
-
新建元数据迁移任务 - 分布式消息服务RocketMQ版
order 否 Boolean 是否有序消息。 perm 否 Integer Topic权限。 readQueueNums 否 Integer 读队列个数。 writeQueueNums 否 Integer 写队列个数。
-
收发顺序消息 - 分布式消息服务RocketMQ版
void main(String[] args) throws ClientException, IOException { final ClientServiceProvider provider = ClientServiceProvider.loadService
-
查询指定实例 - 分布式消息服务RocketMQ版
auto.create.topics.enable,rabbitmq.plugin.management,support.permissive.mode,auto_topic_switch,feature.physerver.kafka.user.manager,kafka.ssl
-
返回结果 - 分布式消息服务RocketMQ版
{ "error_msg": "The format of message is error", "error_code": "AS.0001" } 其中,error_code表示错误码,error_msg表示错误描述信息。 父主题: 如何调用API
-
收发事务消息 - 分布式消息服务RocketMQ版
= nil { log.Fatal(err) } err = producer.Start() if err !
-
查询消费组列表 - 分布式消息服务RocketMQ版
remaining Integer 剩余可创建消费组数量。 next_offset Integer 下个分页的offset。 previous_offset Integer 上个分页的offset。
-
测试4.8.0版本RocketMQ实例性能 - 分布式消息服务RocketMQ版
消息大小:1KB 生产者线程数:测试rocketmq.4u8g.cluster.small、rocketmq.4u8g.cluster和rocketmq.8u16g.cluster时,生产者线程数输入256,测试rocketmq.12u24g.cluster时,生产者线程数输入640
-
收发事务消息 - 分布式消息服务RocketMQ版
producer.setTransactionListener(transactionListener); producer.start(); Message msg = new Message("TopicTest", "
-
收发顺序消息 - 分布式消息服务RocketMQ版
= nil { log.Fatal(err) } err = producer.Start() if err !
-
实现订阅关系一致 - 分布式消息服务RocketMQ版
Consumer1、Consumer2、Consumer3的订阅关系一致,即Consumer1、Consumer2、Consumer3订阅消息的代码必须完全一致,代码示例如下: DefaultMQPushConsumer consumer = new DefaultMQPushConsumer
-
查询所有实例列表 - 分布式消息服务RocketMQ版
feature.physerver.kafka.user.manager,enable.new.authinfo,route,kafka.config.dynamic.modify.enable,kafka.new.pod.port,feature.physerver.kafka.topic.modify
-
修改RocketMQ配置 - 分布式消息服务RocketMQ版
(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
查询主题的授权用户列表 - 分布式消息服务RocketMQ版
perm String 权限。 请求示例 查询主题的授权用户列表。
-
收发普通消息 - 分布式消息服务RocketMQ版
return msg def send_message_sync(): producer = Producer(gid) producer.set_name_server_address(name_srv) producer.start() msg
-
使用ACL权限访问 - 分布式消息服务RocketMQ版
RPCHook rpcHook = new AclClientRPCHook(new SessionCredentials(ACL_ACCESS_KEY, ACL_SECRET_KEY)); DefaultMQProducer producer = new DefaultMQProducer