Skip to content

ConsumerRecord

aiokafka.structs.ConsumerRecord dataclass #

ConsumerRecord(
    topic,
    partition,
    offset,
    timestamp,
    timestamp_type,
    key,
    value,
    checksum,
    serialized_key_size,
    serialized_value_size,
    headers,
)

Bases: Generic[KT, VT]

topic instance-attribute #

topic

The topic this record is received from

partition instance-attribute #

partition

The partition from which this record is received

offset instance-attribute #

offset

The position of this record in the corresponding Kafka partition.

timestamp instance-attribute #

timestamp

The timestamp of this record

timestamp_type instance-attribute #

timestamp_type

The timestamp type of this record

key instance-attribute #

key

The key (or None if no key is specified)

value instance-attribute #

value

The value

checksum instance-attribute #

checksum

Deprecated

serialized_key_size instance-attribute #

serialized_key_size

The size of the serialized, uncompressed key in bytes.

serialized_value_size instance-attribute #

serialized_value_size

The size of the serialized, uncompressed value in bytes.

headers instance-attribute #

headers

The headers