Struct Kafka 

pub struct Kafka {
    pub brokers: Vec<String>,
    pub topic: String,
    pub message_timeout_ms: u32,
    pub properties: BTreeMap<String, String>,
}

[auditor.kafka]: where audit events are produced to.

Fields

brokers: Vec<String>

Bootstrap broker list, e.g. ["kafka.example.com:9092"].

topic: String

Topic every audit event is produced to.

message_timeout_ms: u32

librdkafka message.timeout.ms: how long a queued event keeps retrying delivery before it is dropped (and a warning logged).

properties: BTreeMap<String, String>

Extra librdkafka client properties, passed through verbatim — typically transport security: security.protocol, ssl.ca.location, sasl.mechanism, sasl.username, sasl.password, … Values are never printed (they may hold credentials); only the keys are.

Implementations

impl Kafka

pub fn build_sink(&self) -> Result<KafkaSink, MantaError>

Build the producer. librdkafka connects lazily, so this does not need a reachable broker — but it does validate every property.

Errors

MantaError::KafkaError on an invalid configuration (see client_config) or a property librdkafka rejects.

Trait Implementations

impl Clone for Kafka

fn clone(&self) -> Kafka

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Kafka

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Kafka

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Kafka

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.