Struct ProducerOptiopns

pub struct ProducerOptiopns<'a> { /* private fields */ }

Configuration options for the producer

Implementations

impl<'a> ProducerOptiopns<'a>

pub fn from( bootstrap_servers: String, message_timeout_ms: String, queue_timeout_secs: u64, other_options: HashMap<&'a str, &'a str>, ) -> Self

Creates a new ConsumerOptiopns

Arguments

• bootstrap_servers - Comma separated bootstrap servers
• message_timeout_ms - Message timeout in milliseconds
• queue_timeout_secs - Queue timeout in seconds
• other_options - A HashMap that holds other options that should be used to create the consumer

Example

use simple_kafka::ProducerOptiopns;

let consumer_options = ProducerOptiopns::from("localhost:9092".to_string(), "5000".to_string(),5 HashMap::new());