Reading cloud event avro Message

Elastic Stack Logstash
1

Hi ,
I was trying to find a plugin which is able to read a kafka message which is of format [cloud event avro](https://github.com/cloudevents/spec/blob/v1.0/avro-format.md

eg :

{"data_base64":"LFNSVl9Qb3N0T25lVHJhbnNhY3Rpb24=","id":"4f3f8f5e-78a3-4ec0-ac69-5d1005cea714","source":"Transaction_Post","specversion":"1.0","type":"com.prod.account.balance.update","datacontenttype":"application/avro","dataschema":"/balupdate","time":"2020-07-14T06:09:30.26444Z"}

Here data_base64 is of avro format and needs to be deserialized in logstash. If I send only the data inside data_base64(i.e LFNSVl9Qb3N0T25lVHJhbnNhY3Rpb24=) it is working with logstash avro Plugin.

Is there any solution to use this avro plugin in filter or pass a field name to it ?

2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.