Unlock a world of possibilities! Login now and discover the exclusive benefits awaiting you.
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
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
Thanks for sharing.
I tried this and the Kafka output key is null, also the headers are empty as shown below.
Please advise how to fix this? Thanks.
