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
# }

}