kafka/
client_internals.rs

1//! A crate private module to expose `KafkaClient` internals for use
2//! within this crate but not outside of it.
3
4use crate::client::ProduceMessage;
5use crate::error::Result;
6use crate::producer::ProduceConfirm;
7
8pub trait KafkaClientInternals {
9    fn internal_produce_messages<'a, 'b, I, J>(
10        &mut self,
11        required_acks: i16,
12        ack_timeout: i32,
13        messages: I,
14    ) -> Result<Vec<ProduceConfirm>>
15    where
16        J: AsRef<ProduceMessage<'a, 'b>>,
17        I: IntoIterator<Item = J>;
18}