Struct Kafka 

pub struct Kafka { /* private fields */ }

Implementations

impl Kafka

pub fn new(config: Config) -> Result<Self, String>

pub fn get_topics(&mut self) -> Vec<String>

获取全部主题

pub fn create_topic(&mut self, topic: &str) -> bool

创建主题

pub fn set(&self, topic: &str, key: &str, data: JsonValue) -> bool

生产

pub fn get(&self, topic: &str, key: &str, only: bool) -> JsonValue

消费

pub fn get_client(&self, topic: &str, fun: fn(str: String) -> bool)

消费 监听消息不退出

Trait Implementations

impl Clone for Kafka

fn clone(&self) -> Kafka

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.