要知道Kafka是有一個心跳檢測的機制,每過設定時間發一次請求確保Kafka消費端存活能正常消費消息,而在設置Kafka心跳參數的時候一定要超過業務的處理時間的,如果業務處理不完,Kafka心跳檢測沒有得到正常返回的話,就默認消費端與Kafka客户端斷開連接(簡單描述就是心跳檢測後認為你的Kafka死掉了)。這就是kafka為什麼會頻繁掉線的原因。