1. 程式人生 > >kafka connector啟動一段時間,自動斷開問題解決

kafka connector啟動一段時間,自動斷開問題解決

最近開發使用kafka時,遇到一個問題,當啟動connector後,過段時間會自動斷開,後臺看jps是正常的。

排查nohup.out日誌,發現錯誤:com.mysql.jdbc.exceptions.jdbc4.CommunicationsException

“com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure Last packet sent to the server was 0 ms ago.” 
解決方式:
上述問題是由mysql5資料庫的配置引起的。mysql5將其連線的等待時間(wait_timeout)預設為8小時。在其客戶程式中可以這樣來檢視其值: 
mysql﹥ show global variables like 'wait_timeout'; 
+---------------+---------+ 
| Variable_name | Value | 
+---------------+---------+ 
| wait_timeout | 28800 | 
+---------------+---------+ 
1 row in set (0.00 sec) 
28800 seconds,也就是8小時。 

如果在wait_timeout秒期間內,資料庫連線(java.sql.Connection)一直處於等待狀態,mysql5就將該連線關閉。這時,你的Java應用的連線池仍然合法地持有該連線的引用。當用該連線來進行資料庫操作時,就碰到上述錯誤。這解釋了為什麼我的程式第二天不能登入 的問題。 
你可能會想到在tomcat的資料來源配置中有沒有辦法解決?的確,在jdbc連線url的配置中,你可以附上“autoReconnect=true”,但這僅對mysql5以前的版本起作用。增加“validation query”似乎也無濟於事。 
本人覺得最簡單的辦法,就是對症下藥:既然問題是由mysql5的全域性變數wait_timeout的預設值太小引起的,我們將其改大就好了。 
檢視mysql5的手冊,發現對wait_timeout的最大值分別是24天/365天(windows/linux)。以windows為 例,假設我們要將其設為21天,我們只要修改mysql5的配置檔案“my.ini”(mysql5 installation dir),增加一行:wait_timeout=1814400
需要重新啟動mysql5。 
linux系統配置檔案:/etc/my.cnf 

更快捷的辦法,使用命令:set global wait_timeout=31536000;    設定為365天。