wm.adapter.wmkafka.topic:create

The wm.adapter.wmkafka.topic:create allows the user to create topics with specified number of partitions and replication factor.

Input Parameters

$connectionName(String)	Name of the producer or consumer connection.
topics.name(String)	Name of the topic to be created.
topics.partitions(Integer)	Number of partitions.
topics.replicationFactor(Short)	Number of replications. The topic maintains the replications in the Kafka Cluster.

Output Parameters

topicName	Name of the topic.
isCreated	Indicates if the topic is created.