Skip to content

KafkaRawMessage

faststream.kafka.message.KafkaRawMessage dataclass #

KafkaRawMessage(consumer)

Bases: ConsumerRecord

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

consumer instance-attribute #

consumer