Method OnConsumeAsync

Namespace

AvroSharp.KafkaFlow

Assembly

AvroSharp.KafkaFlow.dll

OnConsumeAsync(IMessageContext)

Gets the type of the message's writer schema.

public ValueTask<Type> OnConsumeAsync(IMessageContext context)

Parameters

context IMessageContext

The consumed message, in Confluent Schema Registry framing.

Returns

ValueTask<Type>

Exceptions

InvalidOperationException

The message isn't in Confluent framing with the schema ID in front, its schema isn't Avro, it isn't a record (or a union whose message branch is a record), or no type has that record.