integerating kafka and dsl