Function Overview

Before using DMS for Kafka, you must purchase a Kafka instance. Your Kafka instance will be deployed in physical isolation and exclusively used by you.

Connect to a Kafka instance using an open-source Kafka client to create and retrieve messages. Depending on whether you enable or disable SASL_SSL, the port for connecting to an instance varies. If you enable SASL_SSL, you will also need to configure certificates.

A topic is a stream of messages. If automatic topic creation is not enabled during instance creation, you need to manually create topics for creating and retrieving messages.
After creating a topic, you can modify its aging time to meet service requirements.

After creating a Kafka instance, you can increase the storage space, broker quantity, and broker flavor.

The storage space can be expanded for a maximum of 20 times.
You can only change instances to higher specifications, but cannot change them to lower specifications.

To access a Kafka instance over a public network, you can enable public access. 

You can view the size, creation time, and body of messages in topics.

Kafka Manager is an open-source tool for managing Kafka, which can be used only through a web browser. In Kafka Manager, you can view the monitoring statistics and broker information about your Kafka clusters.

DMS for Kafka supports ACL permission management for topics. You can differentiate the operations that different users are allowed to perform on a topic by granting the users different permissions.

You can delete consumer groups, reset consumer offsets, and view consumer connection addresses.

Your Kafka instances, topics, and consumers come with default configuration parameter settings. You can modify common parameters on the console.

Tags facilitate Kafka instance identification and management.
You can add tags to a Kafka instance when creating the instance or add tags on the details page of the created instance. Up to 20 tags can be added to an instance.

Cloud Eye monitors Kafka instance metrics in real time. You can view these metrics on the Cloud Eye console.

Kafka operations are recorded by Cloud Trace Service (CTS), which is a log audit service provided by HUAWEI CLOUD. CTS collects, stores, and queries records of operations on Kafka instances, facilitating security analysis, compliance audit, resource tracking, and fault locating.

DMS for Kafka provides REST APIs that support HTTP/HTTPS methods. You can call APIs to create, modify, and delete instances.