IMessageConsumer.OverrideOffsetsAndRestartAsync method

Overrides the offsets of the given partitions and restart the consumer

public Task OverrideOffsetsAndRestartAsync(IReadOnlyCollection<TopicPartitionOffset> offsets)

parameter	description
offsets	The offset values

See Also

• interface IMessageConsumer
• namespace KafkaFlow.Consumers