Check this link : https://www.confluent.io/blog/kafka-connect-sink-for-postgresql-from-justone-database/ https://github.com/justonedb/kafka-sink-pg-json