SingleMessageTypeResolver.OnConsumeAsync method

public ValueTask<Type> OnConsumeAsync(IMessageContext context)

See Also

• class SingleMessageTypeResolver
• namespace KafkaFlow.Middlewares.Serializer.Resolvers