Lib.rs

#SBKafka

轻松消费 rdkafka

导入

use {
    sbkafka::{subscribe,publisher}
};

消费

let consume = subscribe;
let _producer = publisher(&args);
consume(&args,&process_msg).await;

where process_msg 是

fn process_msg(message:&BorrowedMessage) {
    let payload = message
    .payload_view::<str>()
    .unwrap_or(Ok(""))
    .unwrap_or_else(|e| {
        error!("Error while deserializing payload: {:?}", e);
        ""
    });
}

生产

let producer = publisher(&args);