在创建并部署消息队列Kafka版实例后,您可以使用消息队列Kafka版控制台直接发送消息,快速测试服务端是否正常。
前提条件
操作流程
快速测试消息队列Kafka版服务端的流程如下:
您可以多次重复步骤2到步骤4,如果多次操作正常,则说明服务端正常。
说明 如果服务端正常,但发送消息依然失败,建议您去调用方(例如,原生客户端、生态组件端等)排查问题。
创建Topic
创建用于接收消息的Topic。
发送消息
向已创建的Topic发送消息。
- 在Topic 管理页面,找到目标Topic,在其操作列中,选择 。
- 在快速体验消息收发面板,发送测试消息。
- 发送方式选择控制台。
- 在消息 Key文本框中输入消息的Key值,例如demo。
- 在消息内容文本框输入测试的消息内容,例如 {"key": "test"}。
- 设置发送到指定分区,选择是否指定分区。
- 单击是,在分区 ID文本框中输入分区的ID,例如0。如果您需查询分区的ID,请参见查看分区状态。
- 单击否,不指定分区。
- 根据界面提示信息,通过SDK订阅消息,或者执行Docker命令订阅消息。
- 发送方式选择Docker,运行Docker容器。
- 执行运行 Docker 容器生产示例消息区域的Docker命令,发送消息。
- 执行发送后如何消费消息?区域的Docker命令,订阅消息。
- 发送方式选择 SDK,根据您的业务需求,选择需要的语言或者框架的SDK以及接入方式,通过SDK体验消息收发。
- 发送方式选择控制台。
查看分区状态
往指定分区发送消息后,查看该分区的状态。
在Topic 管理页面,找到目标Topic,在其操作列中,选择 。
参数 | 说明 |
---|---|
分区ID | 该Topic分区的ID号。 |
最小位点 | 该Topic在当前分区下的最小消费位点。 |
最大位点 | 该Topic在当前分区下的最大消费位点。 |
最近更新时间 | 本分区中最近一条消息的存储时间。 |
