How to send headers from Pentaho DI to Kafka?

47 views Asked by At

I have a need to pass Kafka headers (key-value pairs that can be attached to Kafka messages to provide metadata and additional information about the message) to send a JSON message to a topic. Please tell me how can I do this in Pentaho 9.2?

My transofrmation with "Kafka producer" step

My "Kafka producer" step

I did try sending JSON-message without required Headers and getting Error: "Description":"Message for the ...., the value of the ... parameter: Must not be empty".

My "Kafka consumer" step

0

There are 0 answers