Parses WKT encoded geography on Logstash event and converts it to GeoJSON.
filter {
wkt_to_geojson {
field => "wkt"
target => "geo_json"
tag_on_parse_failure => [ "wkt_paring_error" ]
}
}
For walk through of developing Logstash filter plugin see https://www.elastic.co/guide/en/logstash/current/_how_to_write_a_logstash_filter_plugin.html