Not getting all Records imported from Logstash to Elasticsearch