pub trait ConsumerExt<C = DefaultConsumerContext>: Consumer<C>where
C: ConsumerContext,{
// Provided method
fn process_protobuf_and_commit<'life0, 'life1, 'async_trait, F, T, Fut, E>(
&'life0 self,
message: Result<BorrowedMessage<'life1>, KafkaError>,
process_fn: F,
mode: CommitMode,
) -> Pin<Box<dyn Future<Output = Result<(), KakfaProcessError>> + Send + 'async_trait>>
where T: Message + Default + 'async_trait,
F: Fn(T) -> Fut + Send + Sync + 'async_trait,
Fut: Future<Output = Result<(), E>> + Send + 'async_trait,
E: Display + 'async_trait,
Self: Sync + 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait { ... }
}Provided Methods§
fn process_protobuf_and_commit<'life0, 'life1, 'async_trait, F, T, Fut, E>( &'life0 self, message: Result<BorrowedMessage<'life1>, KafkaError>, process_fn: F, mode: CommitMode, ) -> Pin<Box<dyn Future<Output = Result<(), KakfaProcessError>> + Send + 'async_trait>>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.