IConsumer.ConsumeAsync method

public ValueTask<ConsumeResult<byte[], byte[]>> ConsumeAsync(CancellationToken cancellationToken)

See Also

• interface IConsumer
• namespace KafkaFlow.Consumers