开发者社区 > 云原生 > 云消息队列 > 正文

如何快速测试消息队列 Kafka 版服务端是否正常?

如何快速测试消息队列 Kafka 版服务端是否正常?

展开
收起
保持可爱mmm 2020-03-28 18:09:18 774 0
1 条回答
写回答
取消 提交回答
  • 登录消息队列 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。 在请输入位点文本框,输入位点。 单击搜索。

    2020-03-28 18:11:02
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 Kafka 版
  • 相关电子书

    更多
    企业互联网架构之消息队列 立即下载
    基于消息队列RocketMQ的大型分布式应用上云最佳实践 立即下载
    云原生消息队列Apache RocketMQ 立即下载