Struct ConsumerBuilder

pub struct ConsumerBuilder { /* private fields */ }

Builder for Consumer

Implementations

impl ConsumerBuilder

pub async fn build(self, stream: &str) -> Result<Consumer, ConsumerCreateError>

pub fn offset(self, offset_specification: OffsetSpecification) -> Self

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

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

pub fn name_optional(self, consumer_name: Option<String>) -> Self

pub fn enable_single_active_consumer( self, is_single_active_consumer: bool, ) -> Self

pub fn filter_input( self, filter_configuration: Option<FilterConfiguration>, ) -> Self

pub fn consumer_update<Fut>( self, consumer_update_listener: impl Fn(u8, MessageContext) -> Fut + Send + Sync + 'static, ) -> Self

where Fut: Future<Output = OffsetSpecification> + Send + Sync + 'static,

pub fn consumer_update_arc( self, consumer_update_listener: Option<Arc<dyn Fn(u8, MessageContext) -> BoxFuture<'static, OffsetSpecification> + Send + Sync>>, ) -> Self

pub fn properties(self, properties: HashMap<String, String>) -> Self