IMessageConsumer.RestartAsync method

Restart KafkaFlow consumer and recreate the internal Confluent Consumer

public Task RestartAsync()

See Also

• interface IMessageConsumer
• namespace KafkaFlow.Consumers