在创建并部署消息队列Kafka版实例后,您可以使用消息队列Kafka版控制台直接发送消息,快速测试服务端是否正常。
前提条件
您已创建并部署
消息队列Kafka版实例,且实例处于
服务中状态。
操作流程
快速测试消息队列Kafka版服务端的流程如下:
- 创建Topic
- 发送消息
- 查看分区状态
- 按位点查询消息
您可以多次重复步骤2到步骤4,如果多次操作正常,则说明服务端正常。
说明 如果服务端正常,但发送消息依然失败,建议您去调用方(例如,原生客户端、生态组件端等)排查问题。
创建Topic
创建用于接收消息的Topic。
- 登录消息队列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。
- 在请输入位点文本框,输入位点。
- 单击搜索。
在文档使用中是否遇到以下问题
更多建议
匿名提交