读取kafka数据,将读取数据写入到文件中,对网络阻塞做出相应的处理