在创建并部署消息队列Kafka版实例后,您可以使用消息队列Kafka版控制台直接发送消息,快速测试服务端是否正常。

前提条件

您已创建并部署消息队列Kafka版实例,且实例处于服务中状态。

操作流程

快速测试消息队列Kafka版服务端的流程如下:

  1. 创建Topic
  2. 发送消息
  3. 查看分区状态
  4. 按位点查询消息

您可以多次重复步骤2到步骤4,如果多次操作正常,则说明服务端正常。

说明 如果服务端正常,但发送消息依然失败,建议您去调用方(例如,原生客户端、生态组件端等)排查问题。

创建Topic

创建用于接收消息的Topic。

  1. 登录消息队列Kafka版控制台
  2. 在左侧导航栏,单击Topic管理
  3. Topic管理页面顶部,选择目标实例,然后单击创建Topic
    create topic
  4. 创建Topic对话框,设置Topic属性,然后单击创建
    createtopic

    字段说明如下:

    • Topic:Topic名称,例如demo。
    • 标签:标签,例如demo。
    • 实例:实例ID,例如alikafka_pre-cn-***。
    • 备注:备注信息,例如demo。
    • 分区数:Topic的分区数量,例如12。

发送消息

往创建的Topic的指定分区发送消息。

  1. Topic管理页面,找到创建的Topic,在其操作列,单击发送消息
    sendmessage
  2. 发送消息对话框,设置分区和消息属性,然后单击发送
    sendmessagesetting

    字段说明如下:

    • 分区:分区ID,例如0。
    • Message Key:消息键,例如demo。
    • Message Value:消息值,例如 {"key": "test"}。

查看分区状态

往指定分区发送消息后,查看该分区的状态。

  1. Topic管理页面,找到发送消息到的Topic,在其操作列,单击分区状态
    sendmessage
  2. 分区状态对话框,单击刷新
    update

按位点查询消息

根据分区ID和位点查询消息。

  1. 在左侧导航栏,单击消息查询
  2. 消息查询页面,选择目标实例,单击按位点查询页签。
    1. 请输入 Topic文本框,输入Topic。
    2. 请选择分区下拉列表,选择发送消息到的分区ID。
    3. 请输入位点文本框,输入位点。
    4. 单击搜索
    query message