Kafka Loader configuration to ingest json received from events in topic to reflect in TG DB

I have setup debezium with mysql on a server. And debezium is able to bring changes in DB. My concern is to load it in tigergraph. As json received from topic are different than tigergraph ingestion. How do I configure kafka loader in tigergraph, to receive these modified changes and ingest in TG.
Also to look into, if delete operations are performed on mysql DB, these should be reflected in TG.