Usage Introduction

Function Description

MQS is a message integration component of ROMA Connect. It uses a unified message access mechanism to provide secure and standard message channels for cross-network access. ROMA Connect has the following advantages for message integration:

• Support for Kafka-native features

  MQS of the Kafka engine is compatible with open-source Kafka APIs and supports all message processing functions of open-source Kafka.

• Secure message transmission

  Operations on MQS instances are recorded and can be audited. Messages can be encrypted before transmission. SASL authentication and security groups are used to enhance network access control.

• High reliability of message data

  MQS instances support data persistence and replication. Messages can be replicated synchronously or asynchronously between replicas.

Process Flow

The following figure shows the process of using ROMA Connect for message integration.

Figure 1 Process of using ROMA Connect for message integration

1. You have created an instance and integration application.
2. Create a topic.

   Create a topic for storing messages so that message producers can publish messages and message consumers can subscribe to messages.

3. (Optional) Grant permissions for topics.

   If SASL_SSL of MQS is enabled in the ROMA Connect instance, the client needs to use the key and secret of the authorized integration application for security authentication when publishing and subscribing to messages to the topic.

4. Connect to the topic.

   The open-source Kafka client needs to be integrated to the system. Then, messages can be produced and consumed through the command lines provided by the client.