input {
file {
path => "C:/TEMP/*.txt"
type => "core2"
start_position => "beginning"
}
}
filter {
}
output {
elasticsearch {
action => "index"
host => "localhost"
cluster => "clustertest"
node_name=> "test"
index => "market"
}
stdout {
codec => rubydebug
}
}