Struct KafkaRestCommitLog

pub struct KafkaRestCommitLog { /* private fields */ }

A commit log holds topics and can be appended to and tailed.

Implementations

impl KafkaRestCommitLog

pub fn new( server: Url, server_cert: Option<Certificate>, tls_insecure: bool, ) -> Self

Establish a new commit log session.

Trait Implementations

impl Clone for KafkaRestCommitLog

fn clone(&self) -> KafkaRestCommitLog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CommitLog for KafkaRestCommitLog

fn scoped_subscribe<'a>( &'a self, consumer_group_name: &str, offsets: Vec<ConsumerOffset>, subscriptions: Vec<Subscription>, idle_timeout: Option<Duration>, ) -> Pin<Box<dyn Stream<Item = ConsumerRecord> + Send + 'a>>

Subscribe to one or more topics for a given consumer group having committed zero or more topics. Connections are retried if they cannot be established, or become lost. Once a connection is established then records are streamed back indefinitely unless an idle timeout argument is provided. In the case of an idle timeout, if no record is received within that period, None is returned to end the stream.

fn offsets<'life0, 'async_trait>( &'life0 self, topic: Topic, partition: u32, ) -> Pin<Box<dyn Future<Output = Option<PartitionOffsets>> + Send + 'async_trait>>

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

Retrieve the current offsets of a topic if they are present.

fn produce<'life0, 'async_trait>( &'life0 self, record: ProducerRecord, ) -> Pin<Box<dyn Future<Output = Result<ProducedOffset, ProducerError>> + Send + 'async_trait>>

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

Publish a record and return the offset that was assigned.