Kafunk


AutoOffsetReset

Namespace: Kafunk

The action to take when the consumer attempts to fetch an offset which is out of range or if the group coordinator does not have offsets for the assigned partitions.

Union Cases

Union CaseDescription
StartFromTime(Time)
Signature: Time

Starts from a specified Time value such as Time.EarliestOffset or Time.EarliestOffset.

Stop
Signature:

Stop the consumer, raising an exception.

TryStartFromCommittedOffsets
Signature:

tries to start from the previously committed offsets, if available and within range, otherwises stops with an exception.

Fork me on GitHub