创建Topic
概述
创建用于存储消息的Topic,供消息生产方发布消息和供消息消费方订阅消息。
前提条件
每个Topic都要归属到某个集成应用下,在创建Topic前您需要有可用的集成应用,否则请提前创建集成应用。
操作步骤
- 登录ROMA Connect控制台,在“实例”页面单击实例上的“查看控制台”,进入实例控制台。
- 在左侧的导航栏选择“消息集成 MQS > Topic管理”,单击页面右上角的“创建Topic”。
- 在创建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的描述信息。