Struct rdkafka::producer::FutureProducer [−][src]
A producer that returns a Future
for every message being produced.
Since message production in rdkafka is asynchronous, the caller cannot
immediately know if the delivery of the message was successful or not. The
FutureProducer provides this information in a Future
, which will be
completed once the information becomes available.
This producer has an internal polling thread and as such it doesn’t need to
be polled. It can be cheaply cloned to get a reference to the same
underlying producer. The internal polling thread will be terminated when the
FutureProducer
goes out of scope.
Implementations
impl<C, R> FutureProducer<C, R> where
C: ClientContext + 'static,
R: AsyncRuntime,
[src]
C: ClientContext + 'static,
R: AsyncRuntime,
pub async fn send<K: ?Sized, P: ?Sized, T>(
&self,
record: FutureRecord<'_, K, P>,
queue_timeout: T
) -> OwnedDeliveryResult where
K: ToBytes,
P: ToBytes,
T: Into<Timeout>,
[src]
&self,
record: FutureRecord<'_, K, P>,
queue_timeout: T
) -> OwnedDeliveryResult where
K: ToBytes,
P: ToBytes,
T: Into<Timeout>,
Sends a message to Kafka, returning the result of the send.
The queue_timeout
parameter controls how long to retry for if the
librdkafka producer queue is full. Set it to Timeout::Never
to retry
forever or Timeout::After(0)
to never block. If the timeout is reached
and the queue is still full, an RDKafkaErrorCode::QueueFull
error will
be reported in the OwnedDeliveryResult
.
Keep in mind that queue_timeout
only applies to the first phase of the
send operation. Once the message is queued, the underlying librdkafka
client has separate timeout parameters that apply, like
delivery.timeout.ms
.
See also the FutureProducer::send_result
method, which will not
retry the queue operation if the queue is full.
pub fn send_result<'a, K: ?Sized, P: ?Sized>(
&self,
record: FutureRecord<'a, K, P>
) -> Result<DeliveryFuture, (KafkaError, FutureRecord<'a, K, P>)> where
K: ToBytes,
P: ToBytes,
[src]
&self,
record: FutureRecord<'a, K, P>
) -> Result<DeliveryFuture, (KafkaError, FutureRecord<'a, K, P>)> where
K: ToBytes,
P: ToBytes,
Like FutureProducer::send
, but if enqueuing fails, an error will be
returned immediately, alongside the FutureRecord
provided.
pub fn poll<T: Into<Timeout>>(&self, timeout: T)
[src]
Polls the internal producer.
This is not normally required since the FutureProducer
has a thread
dedicated to calling poll
regularly.
Trait Implementations
impl<C, R> Clone for FutureProducer<C, R> where
C: ClientContext + 'static,
[src]
C: ClientContext + 'static,
fn clone(&self) -> FutureProducer<C, R>
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl FromClientConfig for FutureProducer
[src]
fn from_config(config: &ClientConfig) -> KafkaResult<FutureProducer>
[src]
impl<C, R> FromClientConfigAndContext<C> for FutureProducer<C, R> where
C: ClientContext + 'static,
R: AsyncRuntime,
[src]
C: ClientContext + 'static,
R: AsyncRuntime,
fn from_config_and_context(
config: &ClientConfig,
context: C
) -> KafkaResult<FutureProducer<C, R>>
[src]
config: &ClientConfig,
context: C
) -> KafkaResult<FutureProducer<C, R>>
impl<C, R> Producer<FutureProducerContext<C>> for FutureProducer<C, R> where
C: ClientContext + 'static,
R: AsyncRuntime,
[src]
C: ClientContext + 'static,
R: AsyncRuntime,
fn client(&self) -> &Client<FutureProducerContext<C>>
[src]
fn flush<T: Into<Timeout>>(&self, timeout: T)
[src]
fn in_flight_count(&self) -> i32
[src]
fn init_transactions<T: Into<Timeout>>(&self, timeout: T) -> KafkaResult<()>
[src]
fn begin_transaction(&self) -> KafkaResult<()>
[src]
fn send_offsets_to_transaction<T: Into<Timeout>>(
&self,
offsets: &TopicPartitionList,
cgm: &ConsumerGroupMetadata,
timeout: T
) -> KafkaResult<()>
[src]
&self,
offsets: &TopicPartitionList,
cgm: &ConsumerGroupMetadata,
timeout: T
) -> KafkaResult<()>
fn commit_transaction<T: Into<Timeout>>(&self, timeout: T) -> KafkaResult<()>
[src]
fn abort_transaction<T: Into<Timeout>>(&self, timeout: T) -> KafkaResult<()>
[src]
fn context(&self) -> &Arc<C>
[src]
Auto Trait Implementations
impl<C = DefaultClientContext, R = TokioRuntime> !RefUnwindSafe for FutureProducer<C, R>
impl<C, R> Send for FutureProducer<C, R> where
R: Send,
R: Send,
impl<C, R> Sync for FutureProducer<C, R> where
R: Sync,
R: Sync,
impl<C, R> Unpin for FutureProducer<C, R> where
R: Unpin,
R: Unpin,
impl<C = DefaultClientContext, R = TokioRuntime> !UnwindSafe for FutureProducer<C, R>
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> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
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>,