Struct Kafka

pub struct Kafka { /* private fields */ }

Implementations

impl Kafka

pub fn default() -> Self

pub fn json(&self) -> JsonValue

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

pub fn connect(config: JsonValue) -> 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.