业务使用介绍

功能简介

消息集成MQS是ROMA Connect的消息集成组件，使用统一的消息接入机制，提供跨网络访问的安全、标准化消息通道。使用ROMA Connect进行消息集成，有如下优势：

• 支持原生Kafka特性

  兼容社区版Kafka的API，具备原生Kafka的所有消息处理特性。

• 支持安全的消息传输

  独有的安全加固体系，提供业务操作云端审计，消息传输加密等有效安全措施。通过SASL认证，安全组等加强网络访问控制。

• 支持消息数据高可靠

  支持消息持久化，多副本存储机制。副本间消息同步、异步复制，数据同步或异步落盘多种方式供您自由选择。

使用流程

使用ROMA Connect进行消息集成的流程如下图所示。

图1 业务使用流程

1. 已创建实例和集成应用。
2. 创建Topic

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

3. 配置Topic授权（可选）

   若ROMA Connect实例开启了MQS的SASL_SSL，客户端向Topic发布和订阅消息时，需要使用授权集成应用的Key和Secret进行安全认证。

4. 连接Topic

   在系统中集成开源的Kafka客户端，然后通过客户端提供的命令行向Topic生产和消费消息。