I would like to share that how can we produce messages on Kafka Cluster by using Talend.
How to do ?
1.It is pretty simple ,we have to give Kafka Server detail with port in Kafkaconnection component and we have to write topic name in Kafka output component .You can see the screenshot as I have subscribed to "test" topic.
2.The datatype of your input should be byte as kafka output takes only "byte" datatype .If our input datatype is a string then we have to use tjava or tjavarow component to perform the transformation (java code "output_row.serializedValue = input_row.users.getBytes()) (https://help.talend.com/display/TalendO … afkaOutput)
Last edited by harkirat (2017-01-04 18:26:37)