Struct sea_streamer_kafka::KafkaProducer

pub struct KafkaProducer { /* private fields */ }

Implementations

impl KafkaProducer

pub fn send_record<K, P>( &self, record: FutureRecord<'_, K, P> ) -> KafkaResult<SendFuture>where K: ToBytes + ?Sized, P: ToBytes + ?Sized,

Send a raw FutureRecord to a stream

pub fn send_message<S: Buffer>( &self, header: MessageHeader, payload: S ) -> KafkaResult<SendFuture>

Send a message to a particular (topic, partition). The timestamp and sequence of MessageHeader is currently ignored.

pub fn in_flight_count(&self) -> i32

Returns the number of messages that are either waiting to be sent or are sent but are waiting to be acknowledged.

pub async fn init_transactions(&mut self) -> KafkaResult<()>

See https://docs.rs/rdkafka/latest/rdkafka/producer/trait.Producer.html#tymethod.init_transactions

Warning

This async method is not cancel safe. You must await this future, and this Producer will be unusable for any operations until it finishes.

pub async fn begin_transaction(&mut self) -> KafkaResult<()>

See https://docs.rs/rdkafka/latest/rdkafka/producer/trait.Producer.html#tymethod.begin_transaction

Warning

This async method is not cancel safe. You must await this future, and this Producer will be unusable for any operations until it finishes.

pub async fn commit_transaction(&mut self) -> KafkaResult<()>

See https://docs.rs/rdkafka/latest/rdkafka/producer/trait.Producer.html#tymethod.commit_transaction

Warning

This async method is not cancel safe. You must await this future, and this Producer will be unusable for any operations until it finishes.

pub async fn abort_transaction(&mut self) -> KafkaResult<()>

See https://docs.rs/rdkafka/latest/rdkafka/producer/trait.Producer.html#tymethod.abort_transaction

Warning

This async method is not cancel safe. You must await this future, and this Producer will be unusable for any operations until it finishes.

pub async fn send_offsets_to_transaction( &mut self, offsets: TopicPartitionList, cgm: ConsumerGroupMetadata ) -> KafkaResult<()>

See https://docs.rs/rdkafka/latest/rdkafka/producer/trait.Producer.html#tymethod.send_offsets_to_transaction

Warning

This async method is not cancel safe. You must await this future, and this Producer will be unusable for any operations until it finishes.

pub async fn flush_with_timeout(&mut self, timeout: Duration) -> KafkaResult<()>

Flush pending messages with a timeout.

Warning

This async method is not cancel safe. You must await this future, and this Producer will be unusable for any operations until it finishes.

Trait Implementations

impl Clone for KafkaProducer

fn clone(&self) -> KafkaProducer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaProducer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Producer for KafkaProducer

type Error = KafkaError

type SendFuture = SendFuture

fn send_to<S: Buffer>( &self, stream: &StreamKey, payload: S ) -> KafkaResult<Self::SendFuture>

Send a message to a particular stream. This function is non-blocking. You don’t have to await the future if you are not interested in the Receipt.

fn end<'async_trait>( self ) -> Pin<Box<dyn Future<Output = KafkaResult<()>> + Send + 'async_trait>>where Self: 'async_trait,

End this producer, only after flushing all it’s pending messages.

fn flush<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = KafkaResult<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Flush all pending messages.

fn anchor(&mut self, stream: StreamKey) -> KafkaResult<()>

Lock this producer to a particular stream. This function can only be called once. Subsequent calls should return StreamErr::AlreadyAnchored error.

fn anchored(&self) -> KafkaResult<&StreamKey>

If the producer is already anchored, return a reference to the StreamKey. If the producer is not anchored, this will return StreamErr::NotAnchored error.

fn send<S>( &self, payload: S ) -> Result<Self::SendFuture, StreamErr<Self::Error>>where S: Buffer,

Send a message to the already anchored stream. This function is non-blocking. You don’t have to await the future if you are not interested in the Receipt.