TsgcWSPClient_Kafka › Methods › CreateTopic

CreateTopic Method

Creates a topic on the Kafka cluster.

Syntax

procedure CreateTopic(const aTopicName: string; aNumPartitions: Integer = 1; aReplicationFactor: Integer = 1);

Parameters

• aTopicName: name of the topic to create.
• aNumPartitions: number of partitions for the topic. Defaults to 1.
• aReplicationFactor: number of replicas for each partition. Defaults to 1.

Remarks

Sends a CreateTopics request to the broker. The replication factor must not exceed the number of available brokers in the cluster.

Example

oKafka.CreateTopic('my-topic', 1, 1);

Back to Methods