Commit offsets

Should be used as the last strategy in the chain, to ensure that offsets are only committed once all processing is complete.

class arroyo.processing.strategies.commit.CommitOffsets(commit: Commit)

Commits offset and records consumer latency metric.

This should always be used as the last step in a chain of processing strategies. It commits offsets back to the broker after all prior processing of that message is completed.