List of all items

Structs

• kafka_log::KafkaMetadataEventLog
• kafka_log::KafkaMetadataLogConfig
• kafka_log::MetadataEventQueueCapacity
• log::InProcessMetadataEventLog
• log::KeyedEvent
• log::MetadataEventRecord
• log::PartitionStart
• manager::MetadataPartitionReadiness
• manager::TopicBasedRemoteLogMetadataManager
• not_ready::NotReadyRlmm
• snapshot::Snapshot
• swappable::SwappableRlmm

Enums

• error::CodecError
• error::MetadataLogError
• error::SnapshotError
• serde::MetadataEvent

Traits

• log::AssignmentHandle
• log::MetadataEventLog

Functions

• partitioning::metadata_partition_for
• partitioning::metadata_partitions_for

Type Aliases

• log::MetadataEventStream
• log::RangeVisitor

Constants

• kafka_log::DEFAULT_METADATA_EVENT_QUEUE_CAPACITY
• kafka_log::DEFAULT_METADATA_FETCH_MAX_BYTES
• kafka_log::DEFAULT_METADATA_FETCH_MAX_WAIT
• kafka_log::DEFAULT_METADATA_FETCH_RETRY_BACKOFF
• kafka_log::DEFAULT_METADATA_TOPIC_CREATE_TIMEOUT
• kafka_log::DEFAULT_MIN_ISR
• kafka_log::DEFAULT_NUM_PARTITIONS
• kafka_log::DEFAULT_REPLICATION
• kafka_log::METADATA_TOPIC
• snapshot::SNAPSHOT_FILE_NAME
• snapshot::SNAPSHOT_FORMAT_VERSION