gistfile1.txt

input {
    redis {
        host => "127.0.0.1"
        port => "6379"
        db => 0
        key => "test_key"
        threads => 48
        data_type => "list"
        batch_count => 250
    }
}

filter {
    metrics {
        meter => [
            "events",
            "%{type}"
        ]
        add_tag => "metric"
        add_field => {
            "useful" => "fields"
            "we"  => "need"
            "and" => "want"
        }
        flush_interval => 5
    }

    if "metric" in [tags] {
        mutate {
            replace => {
                "type" => "metric"
            }
            remove_field => [
                "message"
            ]
        }
    }
}

output {
    elasticsearch {
        hosts => [{all 5 of the client only nodes in the cluster}]
        index => "testing_index"
        timeout => 60
    }
}