我是用的logstash將kafka中的數據同步到elasticsearch。logstash和kafka在同一台服務器,elasticsearch在另外的服務器上。
經過排查,是因為我的logstash所在的服務器系統時間不對,比當前時間晚了好幾天。后來修改了系統時間,重新寫入數據,問題解決。
參考地址:http://blog.chinaunix.net/uid-7549563-id-5779178.html
我是用的logstash將kafka中的數據同步到elasticsearch。logstash和kafka在同一台服務器,elasticsearch在另外的服務器上。
經過排查,是因為我的logstash所在的服務器系統時間不對,比當前時間晚了好幾天。后來修改了系統時間,重新寫入數據,問題解決。
參考地址:http://blog.chinaunix.net/uid-7549563-id-5779178.html
本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。