Module kafka_api::records

Structs

• Header
• MutableRecordBatch
• Record
• RecordBatch
• RecordBatchView
• RecordBatches

Enums

• CompressionType
• TimestampType

Constants

• ATTRIBUTES_OFFSET
• ATTRIBUTE_LENGTH
• BASE_OFFSET_LENGTH
• BASE_OFFSET_OFFSET
• BASE_SEQUENCE_LENGTH
• BASE_SEQUENCE_OFFSET
• BASE_TIMESTAMP_LENGTH
• BASE_TIMESTAMP_OFFSET
• COMPRESSION_CODEC_MASK
• CONTROL_FLAG_MASK
• CRC_LENGTH
• CRC_OFFSET
• DELETE_HORIZON_FLAG_MASK
• HEADER_SIZE_UP_TO_MAGIC
• LAST_OFFSET_DELTA_LENGTH
• LAST_OFFSET_DELTA_OFFSET
• LENGTH_LENGTH
• LENGTH_OFFSET
• LOG_OVERHEAD
• MAGIC_LENGTH
• MAGIC_OFFSET
• MAX_TIMESTAMP_LENGTH
• MAX_TIMESTAMP_OFFSET
• NO_SEQUENCE
• PARTITION_LEADER_EPOCH_LENGTH
• PARTITION_LEADER_EPOCH_OFFSET
• PRODUCER_EPOCH_LENGTH
• PRODUCER_EPOCH_OFFSET
• PRODUCER_ID_LENGTH
• PRODUCER_ID_OFFSET
• RECORDS_COUNT_LENGTH
• RECORDS_COUNT_OFFSET
• RECORDS_OFFSET
• RECORD_BATCH_OVERHEAD
• TIMESTAMP_TYPE_MASK
• TRANSACTIONAL_FLAG_MASK

Functions

• decrement_sequence
  Similar to i32::wrapping_add, but wrap at 0 instead of i32::MIN.
• increment_sequence
  Similar to i32::wrapping_add, but wrap to 0 instead of i32::MIN.