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

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

展开
收起
保持可爱mmm 2020-03-28 18:09:18 813 分享 版权
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-learning.com/

还有其他疑问?
咨询AI助理