kafka0.10.2版本最简单api使用,直接用producerThread和consumerThread