RecordMetadata

class kafka.producer.future.RecordMetadata(topic, partition, topic_partition, offset, timestamp, checksum, serialized_key_size, serialized_value_size, serialized_header_size)

Metadata about a record that has been acknowledged by the broker.

Returned by FutureRecordMetadata.get(), which resolves once the batch containing the record has been acknowledged according to the producer’s acks configuration.

Keyword Arguments:

• topic (str) – The topic the record was appended to.

• partition (int) – The partition the record was appended to.

• topic_partition (TopicPartition) – The (topic, partition) the record was appended to.

• offset (int) – The offset of the record in the topic partition, or -1 if the broker did not assign one (e.g. acks=0).

• timestamp (int) – The timestamp of the record, in milliseconds since the epoch (UTC). For CreateTime this is the producer-supplied timestamp; for LogAppendTime it is the broker-assigned timestamp.

• checksum (int) – Deprecated. The CRC32 checksum of the record, or None. Removed in message format v2 (Kafka 0.11+).

• serialized_key_size (int) – The size of the serialized, uncompressed key in bytes, or -1 if the key is None.

• serialized_value_size (int) – The size of the serialized, uncompressed value in bytes, or -1 if the value is None.

• serialized_header_size (int) – The size of the serialized, uncompressed headers in bytes, or -1 if there are no headers.

checksum

Alias for field number 5

offset

Alias for field number 3

partition

Alias for field number 1

serialized_header_size

Alias for field number 8

serialized_key_size

Alias for field number 6

serialized_value_size

Alias for field number 7

timestamp

Alias for field number 4

topic

Alias for field number 0

topic_partition

Alias for field number 2