kafka高併發消息堆積

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