gistfile1.txt

input {
  redis {
    host => "xxx.com"
    tags  => [ "keywords" ]
    data_type => "list"
    key => "keywords_list"
    codec => json
    db => 2
  }
}
filter {
  if "keywords" in tags {
    mutate {
      remove_field => ["message", "host", "@version", "@timestamp"]
    }
  }
}
output {
   if "keywords" in tags {
    stdout {codec => rubydebug }
    }
}