Trait rdkafka::consumer::Consumer

source · [−]
pub trait Consumer<C = DefaultConsumerContext> where
    C: ConsumerContext, {

Show 26 methods    fn client(&self) -> &Client<C>;

    fn group_metadata(&self) -> Option<ConsumerGroupMetadata>;

    fn subscribe(&self, topics: &[&str]) -> KafkaResult<()>;

    fn unsubscribe(&self);

    fn assign(&self, assignment: &TopicPartitionList) -> KafkaResult<()>;

    fn seek<T: Into<Timeout>>(
        &self, 
        topic: &str, 
        partition: i32, 
        offset: Offset, 
        timeout: T
    ) -> KafkaResult<()>;

    fn commit(
        &self, 
        topic_partition_list: &TopicPartitionList, 
        mode: CommitMode
    ) -> KafkaResult<()>;

    fn commit_consumer_state(&self, mode: CommitMode) -> KafkaResult<()>;

    fn commit_message(
        &self, 
        message: &BorrowedMessage<'_>, 
        mode: CommitMode
    ) -> KafkaResult<()>;

    fn store_offset(
        &self, 
        topic: &str, 
        partition: i32, 
        offset: i64
    ) -> KafkaResult<()>;

    fn store_offset_from_message(
        &self, 
        message: &BorrowedMessage<'_>
    ) -> KafkaResult<()>;

    fn store_offsets(&self, tpl: &TopicPartitionList) -> KafkaResult<()>;

    fn subscription(&self) -> KafkaResult<TopicPartitionList>;

    fn assignment(&self) -> KafkaResult<TopicPartitionList>;

    fn committed<T>(&self, timeout: T) -> KafkaResult<TopicPartitionList>
    where
        T: Into<Timeout>,
        Self: Sized;

    fn committed_offsets<T>(
        &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;

    fn offsets_for_times<T>(
        &self, 
        timestamps: TopicPartitionList, 
        timeout: T
    ) -> KafkaResult<TopicPartitionList>
    where
        T: Into<Timeout>,
        Self: Sized;

    fn position(&self) -> KafkaResult<TopicPartitionList>;

    fn fetch_metadata<T>(
        &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;

    fn fetch_group_list<T>(
        &self, 
        group: Option<&str>, 
        timeout: T
    ) -> KafkaResult<GroupList>
    where
        T: Into<Timeout>,
        Self: Sized;

    fn pause(&self, partitions: &TopicPartitionList) -> KafkaResult<()>;

    fn resume(&self, partitions: &TopicPartitionList) -> KafkaResult<()>;

    fn rebalance_protocol(&self) -> RebalanceProtocol;

    fn context(&self) -> &Arc<C> { ... }

}
Expand description

Common trait for all consumers.

Note about object safety

Doing type erasure on consumers is expected to be rare (eg. Box<dyn Consumer>). Therefore, the API is optimised for the case where a concrete type is available. As a result, some methods are not available on trait objects, since they are generic.

Required methods

Returns the Client underlying this consumer.

Returns the current consumer group metadata associated with the consumer.

If the consumer was not configured with a group.id, returns None. For use with Producer::send_offsets_to_transaction.

Subscribes the consumer to a list of topics.

Unsubscribes the current subscription list.

Manually assigns topics and partitions to the consumer. If used, automatic consumer rebalance won’t be activated.

Seeks to offset for the specified topic and partition. After a successful call to seek, the next poll of the consumer will return the message with offset.

Commits the offset of the specified message. The commit can be sync (blocking), or async. Notice that when a specific offset is committed, all the previous offsets are considered committed as well. Use this method only if you are processing messages in order.

Commits the current consumer state. Notice that if the consumer fails after a message has been received, but before the message has been processed by the user code, this might lead to data loss. Check the “at-least-once delivery” section in the readme for more information.

Commit the provided message. Note that this will also automatically commit every message with lower offset within the same partition.

Stores offset to be used on the next (auto)commit. When using this enable.auto.offset.store should be set to false in the config.

Like Consumer::store_offset, but the offset to store is derived from the provided message.

Store offsets to be used on the next (auto)commit. When using this enable.auto.offset.store should be set to false in the config.

Returns the current topic subscription.

Returns the current partition assignment.

Retrieves the committed offsets for topics and partitions.

Retrieves the committed offsets for specified topics and partitions.

Looks up the offsets for this consumer’s partitions by timestamp.

Looks up the offsets for the specified partitions by timestamp.

Retrieve current positions (offsets) for topics and partitions.

Returns the metadata information for the specified topic, or for all topics in the cluster if no topic is specified.

Returns the low and high watermarks for a specific topic and partition.

Returns the group membership information for the given group. If no group is specified, all groups will be returned.

Pauses consumption for the provided list of partitions.

Resumes consumption for the provided list of partitions.

Reports the rebalance protocol in use.

Provided methods

Returns a reference to the ConsumerContext used to create this consumer.

Implementors