Creating a Topic in a Kafka Instance
Function
This API is used to create a topic in a Kafka instance.
Request
Request parameters
Table 2 describes the parameter.
Parameter |
Type |
Mandatory |
Description |
---|---|---|---|
id |
String |
Yes |
Indicates the name of a topic. A topic name consists of 4 to 64 characters, starts with a letter, and contains only letters, hyphens (-), underscores (_), and digits. |
partition |
Integer |
No |
Indicates the number of topic partitions, which is used to set the number of concurrently consumed messages. Value range: 1–20. Default value: 3. |
replication |
Integer |
No |
Indicates the number of replicas, which is configured to ensure data reliability. Value range: 1–3. Default value: 3. |
sync_replication |
Boolean |
No |
Indicates whether to enable synchronous replication. After this function is enabled, the acks parameter on the producer client must be set to –1. Otherwise, this parameter does not take effect. By default, synchronous replication is disabled. |
retention_time |
Integer |
No |
Indicates the retention period of a message. Its default value is 72. Value range: 1–168. Default value: 72. Unit: hour. |
sync_message_flush |
Boolean |
No |
Indicates whether to enable synchronous flushing. Default value: false. Synchronous flushing compromises performance. |
Example request
{ "id" : "haha", "partition" : 3, "replication" : 3, "sync_replication " : true, "retention_time" : 10, "sync_message_flush" : true }
Status Code
Table 4 describes the status code of successful operations. For details about other status codes, see Status Code.
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot