Module: Kcl::Checkpoints

Defined in:

lib/kcl/checkpoints/sentinel.rb

Overview

Enumeration of the sentinel values of checkpoints. Used during initialization of ShardConsumers to determine the starting point in the shard and to flag that a shard has been completely processed.

Defined Under Namespace

Modules: Sentinel