add kafka support