在创建并部署消息队列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