想通过logstash从kafka读取数据并存入elasticsearch。
来自kafka的每条数据形式如下:
Event [{"feed":"metrics","timestamp":"2019-02-19T03:06:30.848Z","version":"0.13.0","metric":"/total/evictions","value":0}]
我只想要Json部分的数据:
{"feed":"metrics","timestamp":"2019-02-19T03:06:30.848Z","version":"0.13.0","metric":"/total/evictions","value":0}
只将Json部分的数据存入elasticsearch,请问logstash的filter部分应该怎么写呢?