Listens to kafka and insert into a pg database, used for multi org use case. Deploy