Struct KafkaMetadataLogConfig 

pub struct KafkaMetadataLogConfig {

    pub bootstrap: String,
    pub topic: String,
    pub num_partitions: i32,
    pub replication: i32,
    pub min_isr: Option<i32>,
    pub client_id: String,
    pub compacted: bool,
    pub provision_topic: bool,
    pub security: Option<ClientSecurity>,
    pub topic_create_timeout: Time,
    pub fetch_max_wait: Time,
    pub fetch_max_bytes: ByteSize,
    pub fetch_retry_backoff: Time,
    pub event_queue_capacity: MetadataEventQueueCapacity,
    pub dispatch_queue_capacity: ConnectionDispatchQueueCapacity,
    pub frame_max: ClientFrameMax,
}

Construction-time configuration for KafkaMetadataEventLog.

Fields

bootstrap: String

host:port for the Kafka client to bootstrap from. The TBRLMM in a broker connects over loopback to its own listener.

topic: String

Internal topic name. Production deployments keep the default. The field exists so multiple isolated clusters can share an environment in tests.

num_partitions: i32

Number of partitions to create the topic with on first startup. The log ignores this value when the topic already exists, and the existing count wins. The log does not support re-bucketing on partition growth.

replication: i32

Replication factor to create the topic with on first startup. The log ignores this value when the topic already exists.

min_isr: Option<i32>

min.insync.replicas to create the topic with on first startup. None leaves the setting to the cluster default. The log ignores this value when the topic already exists.

client_id: String

client_id for the producer and consumer. It is diagnostic only.

compacted: bool

Provision and maintain this internal topic with log compaction.

provision_topic: bool

Create the topic when it is absent. Read-only tooling disables this.

security: Option<ClientSecurity>

Client TLS/SASL security applied to the producer, the raw client, the admin client, and every per-partition fetch connection. None is plaintext loopback, and it is the default.

topic_create_timeout: Time

Timeout for provisioning the internal topic.

fetch_max_wait: Time

Maximum wait for each per-partition metadata fetch.

fetch_max_bytes: ByteSize

Maximum bytes returned by each per-partition metadata fetch.

fetch_retry_backoff: Time

Backoff after a failed metadata fetch.

event_queue_capacity: MetadataEventQueueCapacity

Capacity of the shared metadata-event delivery queue.

dispatch_queue_capacity: ConnectionDispatchQueueCapacity

Capacity of every outbound Kafka connection’s dispatch queue.

frame_max: ClientFrameMax

Maximum frame size for every outbound Kafka connection.

Implementations

impl KafkaMetadataLogConfig

pub fn new(bootstrap: impl Into<String>) -> Self

Construct a config with the conventional Kafka defaults.

pub fn validate(&self) -> Result<(), String>

Validate values that cross into the Kafka wire client.

Errors

Returns an error for non-positive, non-finite, fractional, or out-of-range wire values, and for a min_isr below one, as Kafka’s remote.log.metadata.topic.min.isr does (atLeast(1)).

Trait Implementations

impl Clone for KafkaMetadataLogConfig

fn clone(&self) -> KafkaMetadataLogConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KafkaMetadataLogConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.