kafka/
client_internals.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
//! A crate private module to expose `KafkaClient` internals for use
//! within this crate but not outside of it.

use crate::client::ProduceMessage;
use crate::error::Result;
use crate::producer::ProduceConfirm;

pub trait KafkaClientInternals {
    fn internal_produce_messages<'a, 'b, I, J>(
        &mut self,
        required_acks: i16,
        ack_timeout: i32,
        messages: I,
    ) -> Result<Vec<ProduceConfirm>>
    where
        J: AsRef<ProduceMessage<'a, 'b>>,
        I: IntoIterator<Item = J>;
}