add kafka datasource and sink to utils