InMemoryCheckpointStore

A CheckpointStore in memory, for tests and samples.

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open suspend override fun list(group: String): List<Checkpoint>
Link copied to clipboard
open suspend override fun load(group: String, subscription: String, partition: Int): Long?
Link copied to clipboard
open suspend override fun save(group: String, subscription: String, partition: Int, position: Long)