Checkpointable Internal Contract

Checkpointable is the internal contract for objects with associated partition offsets that can be checkpointed.

StateManager is the one and only known direct extension contract of the Checkpointable Contract.
Table 1. Checkpointable Contract
Method Description


void checkpoint(final Map<TopicPartition, Long> offsets)

Checkpointing offsets

Used when:


Map<TopicPartition, Long> checkpointed()

Used when:

results matching ""

    No results matching ""