kafka高併發消息堆積

一、 使用Kafka時，消費者每次poll的數據業務處理時間不能超過kafka的max.poll.interval.ms，該參數在kafka0.10.2.1中的默認值是300s,因此要綜合業務處理時間和每次poll的數據數量。線程 二、Java線程池大小的選擇：kafka       （1）對於CPU密集型應用，也就是計算密集型，線程池大小應該設置爲CPU核數+1；線程池       （2）對於I

>>阅读原文<<