{"@timestamp":"2017-01-19T15:42:25.223Z","source":"host_1","level":"INFO","message":"Log event #1"}

input {
 redis {
       host => "redis"
           data_type => "list"
           key => "my-key"
   }

filter {
        grok {
             match => ["message", "%{TIMESTAMP_ISO8601:tstamp}"]
        }

        date {
            match => ["tstamp", "ISO8601"]
             }
    }

output {
           elasticsearch {
           hosts => ["my-elasticsearch-host:9200"]
           index => "my-index"
    }
}