Schema Name Extraction

[ghakobyan-sqsp]

I am looking for a way to add Avro schema (or schemas) name to the output, in addition to the topic. It could be a separate field in @metadata (such as [@metadata][kafka][schema]). In many cases, messages in the same topic are assigned several schema types. In other cases, standard fields are not descriptive enough.

If there's a better way to achieve this, any help would be appreciated.