登录消息队列 Kafka 版控制台。 在左侧导航栏,单击Topic管理。 在Topic管理页面顶部,选择目标实例,然后单击创建Topic。
在创建Topic对话框,设置 Topic 属性,然后单击创建 。 字段说明如下。 Topic:Topic 名称,例如 demo。 标签:标签,例如 demo。 实例:实例 ID,例如 alikafka_pre-cn-***。 备注:备注信息,例如 demo。 分区数:Topic 的分区数量,例如 12。
发送消息 往创建的 Topic 的指定分区发送消息。 在Topic管理页面,找到创建的 Topic,在其操作列,单击发送消息。
在发送消息对话框,设置分区和消息属性,然后单击发送。 字段说明如下。 分区:分区 ID,例如 0。 Message Key:消息键,例如 demo。 Message Value:消息值,例如 {"key": "test"}。
查看分区状态 往指定分区发送消息后,查看该分区的状态。 在Topic管理页面,找到发送消息到的 Topic,在其操作列,单击分区状态。
在分区状态对话框,单击刷新。
按位点查询消息 根据分区 ID 和位点查询消息。 在左侧导航栏,单击消息查询 在消息查询页面,选择目标实例,单击按位点查询页签。 在请输入 Topic文本框,输入 Topic。 从请选择分区下拉列表,选择发送消息到的分区 ID。 在请输入位点文本框,输入位点。 单击搜索。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/