tKafkaInput Storm properties (deprecated)
These properties are used to configure tKafkaInput running in the Storm Job framework.
The Storm tKafkaInput component belongs to the Messaging family.
This component is available in Talend Real Time Big Data Platform and Talend Data Fabric.
The Storm framework is deprecated from Talend 7.1 onwards. Use Talend Jobs for Apache Spark Streaming to accomplish your Streaming related tasks.Basic settings
|
Schema and Edit schema |
A schema is a row description. It defines the number of fields (columns) to be processed and passed on to the next component. When you create a Spark Job, avoid the reserved word line when naming the fields. Note that the schema of this component is read-only. It stores the messages sent from the message producer. |
|
Zookeeper host |
Enter the address of the Zookeeper service of the Kafka system to be used. |
|
Port |
Enter the number of the client listening port of the Zookeeper service to be used. |
| Topic name | Enter the name of the topic from which tKafkaInput receives the feed of messages. |
Usage
|
Usage rule |
In a Talend Storm Job, it is used as a start component. The other components used along with it must be Storm components, too. They generate native Storm code that can be executed directly in a Storm system. For further information about a Talend Storm Job, see the sections describing how to create and configure a Talend Storm Job of the Talend Big Data Getting Started Guide . Note that in this documentation, unless otherwise explicitly stated, a scenario presents only Standard Jobs, that is to say traditional Talend data integration Jobs. |
|
Storm Connection |
You need to use the Storm Configuration tab in the Run view to define the connection to a given Storm system for the whole Job. This connection is effective on a per-Job basis. |