Type Alias ConsumerRecord

A consumed record includes the message plus its position in the log.

type ConsumerRecord = {
    leaderEpoch?: number;
    message: Message;
    offset: bigint;
    partition: number;
    topic: string;
}

Properties

leaderEpoch?: number

Leader epoch at the time of fetch, if available.

message: Message

The message content.

offset: bigint

The offset of this record in the partition.

partition: number

The partition this record was consumed from.

topic: string

The topic this record was consumed from.