Struct br_kafka::Kafka

pub struct Kafka { /* private fields */ }

Implementations

impl Kafka

pub fn connect(config: JsonValue) -> Self

连接

pub fn add_config(&mut self, connection: JsonValue) -> &mut Self

增加配置

pub fn switch_config(&mut self, default: &str) -> &mut Self

切换配置

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 copy of the value.

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

Performs copy-assignment from source.