How to load message on Kafka Cluster by using Talend

Four Stars

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



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.
Highlighted
Six 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.

What’s New for Talend Spring ’19

Join us live for a sneak peek!

Sign up now

Definitive Guide to Data Quality

Create systems and workflow to manage clean data ingestion and data transformation.

Download

Tutorial

Introduction to Talend Open Studio for Data Integration.

Watch

Downloads and Trials

Test drive Talend's enterprise products.

Downloads