Input-jdbc transform row with all columns to json

Elastic Stack Logstash
1

I have a jdbc input plugin. My intention is to read a row and transform all the data into a kafka payload object and send it to kafka.

{
....
"payload" : " All the data from one row of jdbc input should come here"
"timestamp" : "12:45:56"
}

I want it to be a generic solution, and i do not want to transcribe all the fields from sql one by one.
if i can get the name of the field/array in which jdbc_input plugin sends the data that should also work.

or if there is a way to provide the target field which would hold the row by row output of a jdbc-input plugin, please let me know

2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.