This is a very simple Kafka Connect SMT which takes the entire key or value record and transforms it to a new record which contains exactly one field with a JSON representation of the origin record.

support multiple sql statement seperate by semicolon support select, delete, update and insert type support drop, truncate and rename command output the table and column list that the sql visited with ...