interface KafkaCursor

Cursor type for Kafka, tracking position across partitions.

Maps partition numbers to the next offset to consume (the value committed to Kafka / used in seek)

Properties

partitions: Record<number, string>

Mapping of partition number to offset string.

Usage

import { type KafkaCursor } from ".";