- log invalid messages at warning log level
- removing metrics:
- jsonUnrecognized / jsonValid
- schemaUnrecognized / schemaValid
- userBreakdownUnrecognized / userBreakdownValid
- adding metric
- pulsarMessage with everytime filled in tags: topic, contentType, jsonSchema, jsonPathBreakdown
- grouping of partitioned topics
- loading messages as byte array
- expose prometheus metrics
- json validation
- json schema validation
- user break down by json path