Struct kafka::client::KafkaClient [−] [src]

pub struct KafkaClient {
    pub clientid: String,
    pub timeout: i32,
    pub hosts: Vec<String>,
    pub correlation: i32,
    pub conns: HashMap<String, KafkaConnection>,
    pub topic_partitions: HashMap<String, Vec<i32>>,
    pub topic_brokers: HashMap<String, String>,
}

Fields

clientid: String timeout: i32 hosts: Vec<String> correlation: i32 conns: HashMap<String, KafkaConnection> topic_partitions: HashMap<String, Vec<i32>> topic_brokers: HashMap<String, String>

Methods

impl KafkaClient
[src]

fn new(hosts: &Vec<String>) -> KafkaClient

fn init(&mut self)

fn load_metadata_all(&mut self)

fn load_metadata(&mut self, topics: &Vec<String>)

fn reset_metadata(&mut self)

fn fetch_offsets(&mut self)

fn fetch_topic_offset(&mut self, topic: &String) -> Vec<(String, Vec<(i32, i64)>)>

fn fetch_messages(&mut self, topic: &String, partition: i32, offset: i64) -> Vec<OffsetMessage>

fn send_message(&mut self, topic: &String, partition: i32, required_acks: i16, timeout: i32, message: &Vec<u8>)

Trait Implementations

impl Default for KafkaClient
[src]

fn default() -> KafkaClient

Returns the "default value" for a type. Read more

impl Debug for KafkaClient
[src]

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.