add kafka0.8.1 support