- Once the Studio is launched, in the Repository of the Integration perspective, right-click the Storm Jobs node under Job designs, or right-click the Job designs node itself if the Storm Jobs node does not exist yet. and then from the contextual menu, select Create Storm Job to create an empty Job in the workspace.
In the workspace, type in tKafkaInput to display
it in the contextual component list and select it.
The tKafkaInput component is the message input component of a Storm Job. It allows the Job to call the Zookeeper service used by your Kafka cluster.Note that tRowGenerator and tFixedFlowInput are also available as input components that you can use to test the Job being created.
- Add other components available in the Storm components Palette to process the messages depending on the operations you want the Job to perform. Then connect them using the Row > Main link.
At the end of the Job you are designing, add the tJDBCOutput component to write the processed data into a given
You can use tLogRow in place of tJDBCOutput to output the data into the console of the Run view of this Job.
For further explanations of each parameter in this view, see Analyzing people's activities using a Storm topology (deprecated) .
Note that the connection created from this Storm configuration view is effective on a per-Job basis, therefore, when you need to run another Job, you have to configure the connection specific for that Job.
For a detailed scenario running a Storm Job, see Analyzing people's activities using a Storm topology (deprecated) .
You can remotely manage and execute your Storm Jobs from Talend Administration Center. For further information, see Talend Administration Center User Guide.
If you need to deploy and execute a Storm Job on a server independently of the Studio, you can use the Build Job feature to export this Job. For further information about this Build Job feature, see Building Jobs.
You can also create these types of Jobs by writing their Job scripts in the Jobscript view and then generate the Jobs accordingly. For more information on using Job scripts, see Talend Job scripts reference guide at https://help.talend.com/.