IMessageTypeResolver.OnConsumeAsync method

Returns the message type when consuming

public ValueTask<Type> OnConsumeAsync(IMessageContext context)

parameter	description
context	The IMessageContext containing the message and the metadata

See Also

• interface IMessageTypeResolver
• namespace KafkaFlow.Middlewares.Serializer.Resolvers