Struct janus_kafka::SubscriberConfig

pub struct SubscriberConfig { /* fields omitted */ }

Configuration options for a Subscriber

Implementations

impl SubscriberConfig

pub fn brokers(self, brokers: &str) -> Self

Initial list of brokers as a CSV list of broker host or host:port

pub fn group_id(self, group_id: &str) -> Self

Client group id string. All clients sharing the same group.id belong to the same group.

pub fn offset(self, offset: Offset) -> Self

Position for the offset when no initial value.

pub fn buffer_size(self, buffer_size: usize) -> Self

Capacity of ack channel, defaults to 1. Change this to increase consumer throughput.

pub fn topics(self, topics: &[&str]) -> Self

List of topics to subscribe to.

pub fn set(self, key: &str, value: &str) -> Self

Set a librdkafka config directly, for a list of available configuration, see: configuration

Trait Implementations

impl Clone for SubscriberConfig

fn clone(&self) -> SubscriberConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriberConfig

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

Formats the value using the given formatter.

impl Default for SubscriberConfig

fn default() -> Self

Returns the “default value” for a type.