Struct ClusterConfig 

pub struct ClusterConfig {
    pub connection: ConnectionConfig,
    pub retry: RetryPolicy,
    pub refresh_interval: Duration,
    pub max_staleness: Duration,
}

How to build a Cluster.

Fields

connection: ConnectionConfig

Per-connection settings.

retry: RetryPolicy

Retry behaviour for routed requests.

refresh_interval: Duration

How often the background task refreshes metadata.

Kafka’s own client default is five minutes. A UI wants fresher than that, and metadata for a large cluster is not cheap, so thirty seconds is the compromise — with on-demand invalidation doing the real work.

max_staleness: Duration

Refresh before answering when the snapshot is older than this.

Trait Implementations

impl Clone for ClusterConfig

fn clone(&self) -> ClusterConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClusterConfig

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

Formats the value using the given formatter.

impl Default for ClusterConfig

fn default() -> Self

Returns the “default value” for a type.