1、問題：

在使用mqtt進行數據接收并將其轉發到kafka的過程中，出現了個問題，mqtt總是自動斷開并嘗試重連，但是很快就又斷開嘗試重連，如此反復。

報的錯誤為：o.e.p.c.mqttv3.internal.ClientState - 445: Timed out as no activity

在代碼中通過實現 MqttCallbackExtended 接口來進行mqtt的主題訂閱，重連，消息接收等功能；

1）、clientID也使用了時間戳來定義，保證不會出現重復的情況

2）、連接的賬號也使用的最大權限的賬號

但是還是不停的出現斷開并自動重連的情況。

2、解決：

看github上有人提到這個問題：https://github.com/eclipse/paho.mqtt.java/issues/716，但是具體怎么處理，目前還沒給出答案，不過有博客上 ：https://blog.csdn.net/u012134942/article/details/103965155提到應該是mqtt消息太多，服務器處理不過來導致的，這個我去試驗一下。

后記：經過好多次的測試，總算是知道原因了，果然是消息太多服務器處理不過來導致的服務器不斷斷開重連，所以又對很多處理消息的邏輯進行了優化，同時停掉了一些不必要的測試數據，總算是解決了這個問題