Type Alias ProducerState

An active producer on a partition.

type ProducerState = {
    coordinatorEpoch: number;
    currentTxnStartOffset: bigint;
    lastSequence: number;
    lastTimestamp: bigint;
    producerEpoch: number;
    producerId: bigint;
    taggedFields: readonly TaggedField[];
}

Index

Properties

coordinatorEpoch currentTxnStartOffset lastSequence lastTimestamp producerEpoch producerId taggedFields

Properties

`Readonly`coordinatorEpoch

coordinatorEpoch: number

The coordinator epoch, or -1 if not known.

`Readonly`currentTxnStartOffset

currentTxnStartOffset: bigint

The current transaction start offset, or -1 if not in a transaction.

`Readonly`lastSequence

lastSequence: number

The last sequence produced.

`Readonly`lastTimestamp

lastTimestamp: bigint

The last timestamp produced.

`Readonly`producerEpoch

producerEpoch: number

The producer epoch.

`Readonly`producerId

producerId: bigint

The producer ID.

`Readonly`taggedFields

taggedFields: readonly TaggedField[]

Tagged fields.