tencent cloud


Creating Topic

Last updated: 2022-06-24 16:40:13


    Topic is a category name where messages are stored and published. With CKafka, producers write messages to topics, and consumers read messages from topics. To enable horizontal scaling, a topic is divided into multiple partitions. This allows you to horizontally scale your resources by adding more partitions in case of performance bottlenecks.

    This document describes how to create a topic in the CKafka console.


    You have created an instance.


    Step 1. Create a topic

    1. Log in to the CKafka console.
    2. On the Instance List page, click the ID/Name of the target instance to enter the instance details page.
    3. On the instance details page, click Topic Management at the top and click Create.
    4. In the Create Topic window, set the number of partitions and replicas and other parameters.
      • Name: The topic name. It cannot be changed once entered and can contain only letters, digits, underscores, or symbols ("-" and ".").
      • Partition Count: It is a concept in physical partition, where one topic can contain one or more partitions. CKafka uses partition as an allocation unit.
      • Replica Count: The number of partition replicas is used to ensure the high availability of the partition. To ensure data reliability, creating a single-replica topic is not supported. Two replicas are enabled by default.
        Replicas are also counted into the number of partitions. For example, if you create 1 topic with 6 partitions and 2 replicas for each partition, then you have a total of 12 partitions (1 x 6 x 2).
      • Tag: Set a resource tag. For more information, see Tag Overview.
      • Preset ACL Policy: Select the preset ACL policy. For more information on ACL policy, see Configuring ACL Policy.
    5. Click Submit.

    Step 2. Configure advanced topic parameters

    1. On the Instance List page, click the ID/Name of the target instance to enter the instance details page.
    2. On the instance details page, select Topic Management.
    3. In the Operation column, click Edit > Show advanced configuration and set the following parameters:

    The parameters are as detailed below:

    Parameter Default Value Valid Values Description
    cleanup.policy delete delete/compact Log can be deleted by retention time, or can be compacted by key (the compact mode is required for kafka connect).
    min.insync.replicas 1 - When "producer" sets "request.required.acks" to 1, "min.insync.replicas" will specify the minimum number of replicas.
    unclean.leader.election.enable true true/false This parameter specifies whether a replica not in ISR can be set as a leader.
    segment.ms - 1–90 days Segment shard rolling duration in ms. Minimum value: 86,400,000 ms.
    retention.ms Message retention period of the instance 60000 ms–90 days Message retention period at the topic level.
    retention.bytes Message retention size of the instance 1–1024 GB Message retention size at the topic level. If both the message retention period and message retention size are set for a topic, the actual message retention will be determined by which threshold is reached first.
    max.message.bytes - 1 KB–12 MB Maximum message size at the topic level. If this parameter is left empty, it will be 1 MB by default.
    Contact Us

    Contact our sales team or business advisors to help your business.

    Technical Support

    Open a ticket if you're looking for further assistance. Our Ticket is 7x24 avaliable.

    7x24 Phone Support