更新时间:2024-07-31 GMT+08:00

使用控制台连接Kafka

本章节介绍Kafka实例如何在控制台生产消息。此功能通过将指定消息发送给Kafka实例,验证业务逻辑是否正常。

前提条件

  • 仅在实例的“状态”为“运行中”时,才可以在Topic中生产消息。
  • 创建Topic

在控制台生产消息

  1. 登录管理控制台。
  2. 在管理控制台左上角单击,选择区域。

    请选择Kafka实例所在的区域。

  3. 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务Kafka版”,进入分布式消息服务Kafka专享版页面。
  4. 单击Kafka实例名称,进入实例详情页面。
  5. 在左侧导航栏单击“Topic管理”,进入Topic列表页面。
  6. 在待生产消息的Topic所在行,单击“更多 > 生产消息”,弹出“生产消息”对话框。
  7. 参考表1,设置消息的相关参数。

    表1 消息参数

    参数名称

    说明

    消息内容

    输入消息的内容。长度为0~2000个字符。

    消息Key

    输入消息的Key。

    发送到指定分区

    选择是否开启消息发送到指定的分区。

    • 关闭:消息基于Key的hash值选择分区。
    • 开启:消息将发送到指定的分区内。开启“发送到指定分区”后,需要选择分区ID。

  8. 单击“确定”,完成消息的发送。

    消息发送成功后,您可以在“消息查询”页面,查看已成功发送的消息。