spark消费kafka数据，offset存入redis异常：Attempting to read from a broken connection

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

sjw2020

1742人浏览 · 2021-08-17 14:30:10

sjw2020 · 2021-08-17 14:30:10 发布

记录踩过的坑。
前段时间做项目遇到一个异常(Attempting to read from a broken connection)，图已经找不到了，就不贴图了。
项目中使用到了sparkstreaming、redis、kafka等，本地测试使用的setMaster(“local”)单线程调试模式，程序完美运行，集群执行则为多线程运行，跑了一会便报了异常，网上查阅相关资料，发现kafka分区与线程之间关系，线程数量<=kafka分区，调整相关参数完美解决问题，特此记录一下。