Struct StateBackendOffsetStore 

pub struct StateBackendOffsetStore<B: StateBackend> { /* private fields */ }

State backend offset store implementation

Stores offsets in a state backend for durability and recovery.

Implementations

impl<B: StateBackend> StateBackendOffsetStore<B>

pub fn new(backend: Arc<B>) -> Self

Create a new state backend offset store

Arguments

• backend - State backend to use
• prefix - Key prefix for offset storage (default: “kafka_offset:”)

pub fn with_prefix(backend: Arc<B>, prefix: String) -> Self

Create with custom prefix

Trait Implementations

impl<B: StateBackend> OffsetStore for StateBackendOffsetStore<B>

fn store_offset<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, consumer_group: &'life1 str, topic_partition: &'life2 TopicPartition, offset_info: &'life3 OffsetInfo, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Store offset for a topic-partition

fn get_offset<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, consumer_group: &'life1 str, topic_partition: &'life2 TopicPartition, ) -> Pin<Box<dyn Future<Output = StateResult<Option<OffsetInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Retrieve offset for a topic-partition

fn get_all_offsets<'life0, 'life1, 'async_trait>( &'life0 self, consumer_group: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateResult<HashMap<TopicPartition, OffsetInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all offsets for a consumer group

fn delete_offset<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, consumer_group: &'life1 str, topic_partition: &'life2 TopicPartition, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Delete offset for a topic-partition

fn clear_offsets<'life0, 'life1, 'async_trait>( &'life0 self, consumer_group: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Clear all offsets for a consumer group