Struct ConsumerOptiopns

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

Configuration options for Consumers

Implementations

impl<'a> ConsumerOptiopns<'a>

pub fn from( bootstrap_servers: String, group_id: String, session_timeout_ms: String, enable_auto_commit: bool, enable_partition_eof: bool, other_options: HashMap<&'a str, &'a str>, ) -> Self

Creates a new ConsumerOptiopns

Arguments

• bootstrap_servers - Comma separated bootstrap servers
• group_id - The group_id of the consumer
• session_timeout_ms - The session timeout in milliseconds
• enable_auto_commit - Enable auto commit
• enable_partition_eof - Enable partition eof

Example

use simple_kafka::ConsumerOptiopns;

let consumer_options = ConsumerOptiopns::from("localhost:9092".to_string(), "group_id".to_string(), "5000".to_string(), true, true, HashMap::new());