tKafkaCreateTopic
Creates a Kafka topic that the other Kafka components can use.
This component allows you to visually issue the command to create a topic with various topic-level properties.
tKafkaCreateTopic Standard properties
These properties are used to configure tKafkaCreateTopic running in the Standard Job framework.
The Standard
tKafkaCreateTopic component belongs to the Internet family.
The component in this framework is available in all Talend products with Big Data
and in Talend Data Fabric.
Basic settings
Version |
Select the version of the Kafka cluster to be used. |
Use an existing connection |
Select this check box and in the Component List click the relevant connection component to |
Zookeeper quorum list |
Enter the address of the Zookeeper service of the Kafka cluster to be used. The form of this address should be hostname:port. This If you need to specify several addresses, separate them using a comma (,). |
Action on topic |
Select how a topic is created.
|
Topic name |
Enter the name of the topic to be created. |
Replication factor |
Enter the number of the replicas to be created for the logs (the message sets) of the |
Number of partitions |
Enter the number of partitions to be created for the topic. |
Set topic retention time |
Select this check box to define the maximum time in milliseconds during which the contents At the end of the time, the contents are removed or compacted depending on the policy you |
Advanced settings
Topic properties |
Add the Kafka topic properties you need to customize to this table. For further information about the topic-level properties you can define in this table, see |
tStatCatcher Statistics |
Select this check box to gather the processing metadata at the Job |
Usage
Usage rule |
This component is used standalone to create a topic that the other |
Limitation |
Due to license incompatibility, one or more JARs required to use |
Related scenarios
No scenario is available for the Standard version of this component yet.