kafka高并发消息堆积

一、 使用Kafka时,消费者每次poll的数据业务处理时间不能超过kafka的max.poll.interval.ms,该参数在kafka0.10.2.1中的默认值是300s,因此要综合业务处理时间和每次poll的数据数量。线程 二、Java线程池大小的选择:kafka       (1)对于CPU密集型应用,也就是计算密集型,线程池大小应该设置为CPU核数+1;线程池       (2)对于I
相关文章
相关标签/搜索