DeserializerConsumerMiddleware.Invoke method

Deserializes the message using the passed serialized

public Task Invoke(IMessageContext context, MiddlewareDelegate next)

parameter	description
context	The IMessageContext containing the message and metadata
next	A delegate to the next middleware

Exceptions

exception	condition
InvalidOperationException	Throw if message is not byte[]

See Also

• class DeserializerConsumerMiddleware
• namespace KafkaFlow.Middlewares.Serializer