我是用的logstash将kafka中的数据同步到elasticsearch。logstash和kafka在同一台服务器，elasticsearch在另外的服务器上。
经过排查，是因为我的logstash所在的服务器系统时间不对，比当前时间晚了好几天。后来修改了系统时间，重新写入数据，问题解决。
参考地址：http://blog.chinaunix.net/uid-7549563-id-5779178.html
免责声明！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。