How to construct geo_point field in logstash from Kafka input? This is my logstash config file. But Kibana not recognizing as a geo_point field.
input {
kafka {
bootstrap_servers => "localhost:9095"
topics => ["ma_readings", "sms_log"]
decorate_events => true
}
}
filter {
json {
source => "message"
remove_field => ["message"]
}
if [@metadata][kafka][topic] == "ma_readings" {
mutate{
add_field => { "Location" => ["%{Lat}","%{Lon}"] }
remove_field => ["Lat", "Lon"]
}
mutate {
convert => { "Location" => "float" }
}
}
}
output {
elasticsearch {
hosts => ["https://localhost:9200"]
index => "%{[@metadata][kafka][topic]}"
workers => 1
user => 'logstash_internal2'
password => 'logstash_internal2'
ssl_certificate_verification => false
}
"Location": [
6.0181456,
80.71436
]