检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
管理消费组 创建RocketMQ消费组 查看RocketMQ消费组详情 查看RocketMQ消费者连接地址 修改RocketMQ消费组配置 重置RocketMQ消费进度 删除RocketMQ消费组
publicip_id 否 String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 响应参数 无 请求示例 修改RocketMQ实例的名称和描述信息。
弹性IP地址 开启公网访问时,才需要配置弹性IP地址。 在创建弹性IP地址时,应注意如下要求: 创建的弹性IP地址与RocketMQ实例在相同的区域。 RocketMQ控制台无法识别开启IPv6转换功能的弹性IP地址。 创建弹性IP地址的操作指导请参考申请弹性公网IP。
Endpoint:输入grpc连接地址/grpc公网连接地址。 AccessKey:创建实例时,如果开启了ACL,需要输入用户名。 SecretKey:创建实例时,如果开启了ACL,需要输入用户密钥。 父主题: Go(gRPC协议)
publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 publicip_address String 公网IP地址。
”,即11中记录的连接地址。
单位:毫秒 消费地址 消费者的IP地址。 父主题: 管理消息
publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 publicip_address String 公网IP地址。
/grpc公网连接地址 String endpoints = "yourEndpoints"; // 创建实例时,如果开启了ACL才需要添加以下代码。
public static void main(String[] args) { DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName"); //填入连接地址
192.168.0.1:8100:表示实例连接地址和端口。 TopicTest:表示Topic名称。 父主题: Python(TCP协议)
name_srv:表示实例连接地址和端口。 ACL_ACCESS_KEY:表示用户名。创建用户的步骤,请参见创建用户。 ACL_SECRET_KEY:表示用户的密钥。 事务消息,参考如下代码。以下加粗内容需要替换为实例自有信息,请根据实际情况替换。
您可以查看到消费组状态是否在线、消费者数量、订阅关系是否一致和消息堆积量,并根据结果分析处理生产和消费消息时所遇到的问题。 图1 诊断结果 消费组不在线时,可以诊断成功,但是会显示1项异常。 导出诊断记录 登录管理控制台。 在管理控制台左上角单击,选择区域。
Endpoint:输入grpc连接地址/grpc公网连接地址。 AccessKey:创建实例时,如果开启了ACL,需要输入用户名。 SecretKey:创建实例时,如果开启了ACL,需要输入用户密钥。 SetKeys:输入消息的Key。 SetTag:输入消息的Tag。
192.168.0.1:8100:表示实例连接地址和端口。 test:表示Topic名称。 父主题: Go(TCP协议)
name_srv:表示实例连接地址和端口。 订阅普通消息 参考如下示例代码(以下加粗内容需要替换为实例自有信息,请根据实际情况替换)。
Endpoint:输入grpc连接地址/grpc公网连接地址。 AccessKey:创建实例时,如果开启了ACL,需要输入用户名。 SecretKey:创建实例时,如果开启了ACL,需要输入用户密钥。 SetKeys:输入消息的Key。 SetTag:输入消息的Tag。
支持区域: 全部 扩容存储空间或代理个数 公网访问 您需要通过公网地址访问RocketMQ实例时,开启实例的公网访问功能,并设置弹性IP地址。 只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。
192.168.0.1:8100:表示实例连接地址和端口。 AccessKey:表示用户名。创建用户的步骤,请参见创建用户。 SecretKey:表示用户的密钥。 topic1:表示Topic名称。
args) { try { DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name"); //填入连接地址