Creating a Topic

A topic is a stream of messages. If automatic topic creation is not enabled during Kafka instance creation, you need to manually create topics for creating and retrieving messages. If automatic topic creation has been enabled for the instance, this operation is optional.

If automatic topic creation is enabled, the system automatically creates a topic when a message is created in or retrieved from a topic that does not exist. This topic has the following default settings: 3 partitions, 3 replicas, aging time of 72 hours, and synchronous replication and flushing disabled. After you change the value of the log.retention.hours, default.replication.factor, or num.partitions parameter, automatically created topics later use the new value. For example, if num.partitions is set to 5, an automatically created topic will have the following settings: 5 partitions, 3 replicas, aging time 72 hours, and synchronous replication and flushing disabled.

There is a limit on the total number of partitions in topics. When the partition quantity limit is reached, you can no longer create topics. The total number of partitions varies with instance specifications. For details, see Specifications.

Methods that can be used to manually create a topic:

Method 1: Creating a Topic on the Console
Method 2: Creating a Topic on Kafka Manager
Method 3: Creating a Topic by Using Kafka CLI

If an instance node is faulty, an internal service error may be reported when you query messages in a topic with only one replica. Therefore, you are not advised using a topic with only one replica.

Method 1: Creating a Topic on the Console

Log in to the management console.
Click in the upper left corner to select a region.

Select the region where your Kafka instance is located.
Click and choose Application > Distributed Message Service (for Kafka) to open the console of DMS for Kafka.
Click the desired Kafka instance to view the instance details.
In the navigation pane, choose Topics. Then click Create Topic.

Figure 1 Creating a topic

Specify the topic parameters listed in the following table.

**Table 1** Topic parameters
Parameter	Description
Topic Name	When creating a topic, you can modify the automatically generated topic name. Once the topic is created, you cannot modify its name.
Partitions	A larger number of partitions for a topic indicates more messages retrieved concurrently. If this parameter is set to 1, messages will be retrieved in the FIFO order. Value range: 1 to 100 Default value: 3
Replicas	A higher number of replicas delivers higher reliability. Data is automatically backed up on each replica. When one Kafka broker becomes faulty, data is still available on other brokers. If this parameter is set to 1, only one set of data is available. Default value: 3 NOTE: If an instance node is faulty, an internal service error may be reported when you query messages in a topic with only one replica. Therefore, you are not advised using a topic with only one replica.
Aging Time (h)	The period that messages are retained for. Consumers must retrieve messages before this period ends. Otherwise, the messages will be deleted and can no longer be retrieved. Value range: 1 to 168 Default value: 72
Synchronous Replication	A message is returned to the client only after the message creation request has been received and the message has been acknowledged by all replicas. After enabling synchronous replication, set acks to all or –1 on the client. Otherwise, this function will not take effect. If there is only one replica, synchronous replication cannot be enabled.
Synchronous Flushing	An indicator of whether a message is immediately flushed to disk once created. Enabled: A message is immediately flushed to disk once it is created, resulting in higher reliability. Disabled: A message is stored in the memory instead of being immediately flushed to disk once created.

Click OK.

Method 2: Creating a Topic on Kafka Manager

Figure 2 Creating a topic on Kafka Manager

If a topic name starts with a special character, for example, a number sign (#), monitoring data cannot be displayed.

Method 3: Creating a Topic by Using Kafka CLI

If your client is v2.2 or later, you can use kafka-topics.sh to create topics and manage topic parameters.

If a topic name starts with a special character, for example, a number sign (#), monitoring data cannot be displayed.

If SASL is not enabled for the Kafka instance, run the following command in the /{directory where the CLI is located}/kafka_{version}/bin/ directory to create a topic:
```
./kafka-topics.sh --create --topic {topic_name} --bootstrap-server {broker_ip}:{port} --partitions {partition_num} --replication-factor {replication_num}
```
If SASL has been enabled for the Kafka instance, perform the following steps to create a topic:
1. (Optional) If the SSL certificate configuration has been set, skip this step. Otherwise, perform the following operations:
  Create the ssl-user-config.properties file in the /config directory of the Kafka client and add the SSL certificate configurations by referring to 3.
2. Run the following command in the /{directory where the CLI is located}/kafka_{version}/bin/ directory to create a topic:
```
./kafka-topics.sh --create --topic {topic_name} --bootstrap-server {broker_ip}:{port} --partitions {partition_num} --replication-factor {replication_num} --command-config ./config/ssl-user-config.properties 
```