我是用的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