记录踩过的坑。前段时间做项目遇到一个异常(Attempting to read from a broken connection)，图已经找不到了，就不贴图了。使用到redis主要用于记录kafka的offset，本地测试使用的setMaster(“local”)单线程调试模式，程序完美运行，集群执行则为多线程运行，跑了一会便报了异常，网上查阅相关自恋，发现kafka分区与线程之间关系，线程数量&