In the Integration perspective of Talend Studio,
create two empty Standard Jobs from the Job
Designs node in the Repository
tree view.
In the workspace, enter the name of the component to be used and
select this component from the list that appears. In this scenario, the components
are tFixedFlowInput, , two tJavaRow,
tKafkaInput, tKafkaOutput for the
reading Job and tFixedFlowInput, tJavaRow, tKafkaOutput for the writing Job.
The tFixedFlowInput component
is used to load the sample data into the data flow. In the real-world practice, you
can use other components such as tFileInputDelimited, alone or even with a tMap, in the place of tFixedFlowInput to design a sophisticated process to prepare your
data to be processed.
For the reading Job:
Connect tFixedFlowInput to the first
tJavaRow and then connect
tJavaRow to tKafkaOutput using
the Row > Main link.
Connect tKafkaInput to the second
tJavaRow and then connect
tJavaRow to tLogRow using the
Row > Main link.
Link the two parts of the Job using the Trigger > On SubJob
Ok link.
For the writing Job, connect tFixedFlowInput to
tJavaRow and then connect
tJavaRow to tKafkaOutput using
the Row > Main link.
Results
The reading and writing Jobs are set up.
Did this page help you?
If you find any issues with this page or its content – a typo, a missing step, or a technical error – please let us know!