log4j2通过tcp发送json日志到logstash Elasticsearch

log4j2 tcp 方式 发送json数据到logstash

<Configuration>
<Appenders>
<Socket name="Socket" host="localhost" port="12345">
<JsonLayout compact="true" eventEol="true" />
</Socket>
</Appenders>
<Loggers>
<Root level="info">
<AppenderRef ref="Socket"/>
</Root>
</Loggers>
</Configuration>

input {
tcp {

host => "192.168.0.153"
port => 4567
#codec => plain { charset => "GB2312" }
codec => json
}
}

filter {
json {
source => "message"
add_field => ["type", "%{dtype}"]
remove_field => [ "server", "server.fqdn", "timestamp" ]
}
}

output {

if "_jsonparsefailure" not in [tags] {
stdout { codec => rubydebug }
elasticsearch {
hosts => "192.168.2.181:9200"
}
}
}