Updated on 2023-10-08 GMT+08:00


This document takes the example of creating and connecting to a Kafka instance with SASL enabled to get you quickly started with Distributed Message Service (DMS) for Kafka.

You can also create a Kafka instance by calling an API and connect to the instance in your service code.


Figure 1 Procedure for using DMS for Kafka
  1. Prepare the environment.

    A Kafka instance runs in a Virtual Private Cloud (VPC). Before creating a Kafka instance, ensure that a VPC is available.

    After a Kafka instance is created, download and install the Kafka open-source client on your ECS before creating and retrieving messages.

  2. Create a Kafka instance.

    You can select the specification and quantity and enable SASL when creating a Kafka instance. Enabling SASL secures data transmission with encryption.

  3. (Optional) Create a topic.

    If automatic topic creation is not enabled during Kafka instance creation, you need to manually create topics for creating and retrieving messages.

  4. Connect to the instance.

    After SASL is enabled, download a certificate and set the instance connection information in the client configuration file.

  5. Configure alarm rules.

    Configure alarm rules for a Kafka instance to monitor the service running status.

For details about Kafka concepts, see Basic Concepts.