Struct KafkaConfigSource 

pub struct KafkaConfigSource<'a> {
    pub blob: &'a [u8],
    pub app: &'a str,
    pub jitter: Duration,
}

Where producers take their initial Kafka config from, and how they reload it.

Fields

blob: &'a [u8]

The Kafka config blob the initial clients are resolved from.

app: &'a str

Which application’s overrides in the blob apply. For Relay, "relay".

jitter: Duration

Upper bound on the random delay before a swap, to spread swaps across the fleet.

Trait Implementations

impl<'a> Clone for KafkaConfigSource<'a>

fn clone(&self) -> KafkaConfigSource<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for KafkaConfigSource<'a>

impl<'a> Debug for KafkaConfigSource<'a>

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

Formats the value using the given formatter.