input {
file { path => "your_ruby_project_absolute_path/log/*.log.elk" # start_position => "beginning" }
}
filter {
json { source => "message" remove_field => ["@version", "@timestamp", "path", "host", "message"] }
}
output {
kafka { bootstrap_servers => "your_kafka_bootstrap_servers" topic_id => "EAGLEYE_LOG_CHANNEL" } # stdout { # codec => rubydebug # }
}