Docs.rs
  • kafka-api-0.4.1
    • kafka-api 0.4.1
    • Permalink
    • Docs.rs crate page
    • Apache-2.0
    • Links
    • Repository
    • crates.io
    • Source
    • Owners
    • tisonkun
    • Dependencies
      • byteorder ^1.5 normal
      • uuid ^1.8 normal
    • Versions
    • 47.36% of the crate is documented
  • Platform
    • i686-pc-windows-msvc
    • i686-unknown-linux-gnu
    • x86_64-apple-darwin
    • x86_64-pc-windows-msvc
    • x86_64-unknown-linux-gnu
  • Feature flags
  • docs.rs
    • About docs.rs
    • Privacy policy
  • Rust
    • Rust website
    • The Book
    • Standard Library API Reference
    • Rust by Example
    • The Cargo Guide
    • Clippy Documentation

kafka_api0.4.1

Module records

Module Items

  • Structs
  • Enums
  • Constants
  • Functions

In crate kafka_api

kafka_api

Module records

Source

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.