One Star

How to load message on Kafka Cluster by using Talend

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/search/all?query=tKafkaOutput&content-lang=en)
Job screenshot



2 REPLIES
Moderator

Re: How to load message on Kafka Cluster by using Talend

Hi harkirat,
Thanks for sharing your screenshots and experience on forum.
Best regards
Sabrina
--
Don't forget to give kudos when a reply is helpful and click Accept the solution when you think you're good with it.
Five Stars

Re: How to load message on Kafka Cluster by using Talend

This is good information. I played around with this over the weekend and it opens up doors do performing "real-time" data provisioning.