Message validator for Kafka/RabbitMQ/Anything through AsyncAPI schema
validateByMessageId()
method, which only requires key
and value
. To use this method, your AsyncAPI schema should be >= 2.4.0. messageId
should be defined in schema as per AsyncAPI 2.4.0 schema definition.msgIdentifier
option is only required if you use .validate()
method.validateByMessageId()
and validate()
methods if your AsyncAPI schema version is >= 2.4.0ajv-formats
for custom formats.path
parameter for relative ref.fromSource()
._schema
property from instance. Use .schema
instead.channel
, operation
and options.msgIdentifier
are required for validation.-Fixed validation for schema without components.