Struct rdkafka::consumer::stream_consumer::StreamConsumerContext [−][src]
A consumer context wrapper for a stream consumer.
This context will automatically wake up the message stream when new data is available.
This type is not intended to be used directly. The construction of a
StreamConsumer
automatically wraps the underlying context in this type.
Trait Implementations
impl<C> ClientContext for StreamConsumerContext<C> where
C: ConsumerContext,
[src]
C: ConsumerContext,
fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)
[src]
fn stats(&self, statistics: Statistics)
[src]
fn error(&self, error: KafkaError, reason: &str)
[src]
impl<C, R> Consumer<StreamConsumerContext<C>> for StreamConsumer<C, R> where
C: ConsumerContext,
[src]
C: ConsumerContext,
fn client(&self) -> &Client<StreamConsumerContext<C>>
[src]
fn group_metadata(&self) -> Option<ConsumerGroupMetadata>
[src]
fn subscribe(&self, topics: &[&str]) -> KafkaResult<()>
[src]
fn unsubscribe(&self)
[src]
fn assign(&self, assignment: &TopicPartitionList) -> KafkaResult<()>
[src]
fn seek<T: Into<Timeout>>(
&self,
topic: &str,
partition: i32,
offset: Offset,
timeout: T
) -> KafkaResult<()>
[src]
&self,
topic: &str,
partition: i32,
offset: Offset,
timeout: T
) -> KafkaResult<()>
fn commit(
&self,
topic_partition_list: &TopicPartitionList,
mode: CommitMode
) -> KafkaResult<()>
[src]
&self,
topic_partition_list: &TopicPartitionList,
mode: CommitMode
) -> KafkaResult<()>
fn commit_consumer_state(&self, mode: CommitMode) -> KafkaResult<()>
[src]
fn commit_message(
&self,
message: &BorrowedMessage<'_>,
mode: CommitMode
) -> KafkaResult<()>
[src]
&self,
message: &BorrowedMessage<'_>,
mode: CommitMode
) -> KafkaResult<()>
fn store_offset(&self, message: &BorrowedMessage<'_>) -> KafkaResult<()>
[src]
fn store_offsets(&self, tpl: &TopicPartitionList) -> KafkaResult<()>
[src]
fn subscription(&self) -> KafkaResult<TopicPartitionList>
[src]
fn assignment(&self) -> KafkaResult<TopicPartitionList>
[src]
fn committed<T>(&self, timeout: T) -> KafkaResult<TopicPartitionList> where
T: Into<Timeout>,
Self: Sized,
[src]
T: Into<Timeout>,
Self: Sized,
fn committed_offsets<T>(
&self,
tpl: TopicPartitionList,
timeout: T
) -> KafkaResult<TopicPartitionList> where
T: Into<Timeout>,
[src]
&self,
tpl: TopicPartitionList,
timeout: T
) -> KafkaResult<TopicPartitionList> where
T: Into<Timeout>,
fn offsets_for_timestamp<T>(
&self,
timestamp: i64,
timeout: T
) -> KafkaResult<TopicPartitionList> where
T: Into<Timeout>,
Self: Sized,
[src]
&self,
timestamp: i64,
timeout: T
) -> KafkaResult<TopicPartitionList> where
T: Into<Timeout>,
Self: Sized,
fn offsets_for_times<T>(
&self,
timestamps: TopicPartitionList,
timeout: T
) -> KafkaResult<TopicPartitionList> where
T: Into<Timeout>,
Self: Sized,
[src]
&self,
timestamps: TopicPartitionList,
timeout: T
) -> KafkaResult<TopicPartitionList> where
T: Into<Timeout>,
Self: Sized,
fn position(&self) -> KafkaResult<TopicPartitionList>
[src]
fn fetch_metadata<T>(
&self,
topic: Option<&str>,
timeout: T
) -> KafkaResult<Metadata> where
T: Into<Timeout>,
Self: Sized,
[src]
&self,
topic: Option<&str>,
timeout: T
) -> KafkaResult<Metadata> where
T: Into<Timeout>,
Self: Sized,
fn fetch_watermarks<T>(
&self,
topic: &str,
partition: i32,
timeout: T
) -> KafkaResult<(i64, i64)> where
T: Into<Timeout>,
Self: Sized,
[src]
&self,
topic: &str,
partition: i32,
timeout: T
) -> KafkaResult<(i64, i64)> where
T: Into<Timeout>,
Self: Sized,
fn fetch_group_list<T>(
&self,
group: Option<&str>,
timeout: T
) -> KafkaResult<GroupList> where
T: Into<Timeout>,
Self: Sized,
[src]
&self,
group: Option<&str>,
timeout: T
) -> KafkaResult<GroupList> where
T: Into<Timeout>,
Self: Sized,
fn pause(&self, partitions: &TopicPartitionList) -> KafkaResult<()>
[src]
fn resume(&self, partitions: &TopicPartitionList) -> KafkaResult<()>
[src]
fn context(&self) -> &Arc<C>
[src]
impl<C> ConsumerContext for StreamConsumerContext<C> where
C: ConsumerContext,
[src]
C: ConsumerContext,
fn rebalance(
&self,
native_client: &NativeClient,
err: RDKafkaRespErr,
tpl: &mut TopicPartitionList
)
[src]
&self,
native_client: &NativeClient,
err: RDKafkaRespErr,
tpl: &mut TopicPartitionList
)
fn pre_rebalance<'a>(&self, rebalance: &Rebalance<'a>)
[src]
fn post_rebalance<'a>(&self, rebalance: &Rebalance<'a>)
[src]
fn commit_callback(&self, result: KafkaResult<()>, offsets: &TopicPartitionList)
[src]
fn main_queue_min_poll_interval(&self) -> Timeout
[src]
fn message_queue_nonempty_callback(&self)
[src]
Auto Trait Implementations
impl<C> RefUnwindSafe for StreamConsumerContext<C> where
C: RefUnwindSafe,
[src]
C: RefUnwindSafe,
impl<C> Send for StreamConsumerContext<C>
[src]
impl<C> Sync for StreamConsumerContext<C>
[src]
impl<C> Unpin for StreamConsumerContext<C> where
C: Unpin,
[src]
C: Unpin,
impl<C> UnwindSafe for StreamConsumerContext<C> where
C: UnwindSafe,
[src]
C: UnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,