You are not logged in.

Unanswered posts



Important! This site has been replaced. All content here is read-only. Please visit our brand-new community at https://community.talend.com/. We look forward to hearing from you there!



#1 2017-01-04 18:11:42

harkirat
Member
10 posts

harkirat said:

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/display/TalendO … afkaOutput)
Job screenshot

mini_blob_20170104-0918.png

mini_blob_20170104-0920.png

mini_blob_20170104-0921.png


mini_blob_20170104-0922.png

Last edited by harkirat (2017-01-04 18:26:37)

Offline

#2 2017-01-05 09:29:24

xdshi
Talend Team


xdshi said:

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


What we can do is to make sure that Talend will be your best choice!

Offline

#3 2017-04-03 14:43:15

dsietz
Member
40 posts

dsietz said:

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.

Offline

Board footer

Talend Contributor Agreement - Talend Website Privacy Policy