IMessageTypeResolver.OnProduceAsync method

Stores the message type somewhere when producing

public ValueTask OnProduceAsync(IMessageContext context)

parameter	description
context	The IMessageContext containing the message and the metadata

See Also

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