更新时间:2024-06-25 GMT+08:00

创建Topic

概述

创建用于存储消息的Topic,供消息生产方发布消息和供消息消费方订阅消息。

前提条件

每个Topic都要归属到某个集成应用下,在创建Topic前您需要有可用的集成应用,否则请提前创建集成应用

操作步骤

  1. 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。
  2. 在左侧的导航栏选择“消息集成 MQS > Topic管理”,单击页面右上角的“创建Topic”。
  3. 在创建Topic弹窗中配置Topic相关信息,完成后单击“确定”。
    表1 Topic信息配置

    参数

    配置说明

    Topic名称

    填写Topic的名称,根据规划自定义。建议您按照一定的命名规则填写Topic名称,方便您快速识别和查找。

    说明:

    Topic不能以“.”和“_”来区分不同的名称,例如先创建了名称为“Topic.test”的Topic,则再创建名称“Topic_test”的Topic时会创建失败。

    集成应用

    选择Topic所属的集成应用。

    权限

    为Topic所属的集成应用选择对Topic的操作权限。

    • 发布+订阅:表示支持对Topic发布消息和订阅消息。
    • 发布:表示仅支持对Topic发布消息。
    • 订阅:表示仅支持对Topic订阅消息。

    分区数

    设置Topic的分区数,合理设置分区数量,可以提升消息生产与消费的并发性能。

    分区数设置为1时,消费消息时可按照先入先出的顺序进行消费。

    副本数

    设置Topic的副本数,ROMA Connect会自动在每个副本上备份数据,当其中一个副本故障时数据依然可用,Topic的副本数越多,可靠性越高。

    说明:

    实例节点出现故障的情况下,单副本Topic查询消息时会出现内部错误问题,因此不建议使用单副本Topic。

    老化时间(小时)

    设置Topic中存储消息的老化时间,超过老化时间的消息将会被删除。

    同步复制

    客户端向Topic生产消息时,是否把消息复制给所有副本,然后才向消息客户端返回响应。

    开启同步复制后,需要同时在客户端配置acks=-1,否则同步复制无效。

    同步落盘

    消息客户端向Topic生产的每条消息是否立即写入磁盘。同步落盘开启时,可靠性更高。

    标签

    为Topic所属的集成应用添加消息发布和订阅标签,一般业务场景下无需添加,仅用于特殊业务场景。

    添加标签后,客户端向Topic发布和订阅消息时需同时传输标签信息。如果有多个标签,则客户端传输的标签需为Topic包含标签的子集。

    敏感字段

    填写Topic的消息敏感字段。若向Topic生成的消息中包含敏感字段,则包含敏感字段的整条消息内容会被屏蔽。

    描述

    填写Topic的描述信息。