Function kafka_threadpool::start_threadpool::start_threadpool

source · [−]
pub async fn start_threadpool(label: Option<&str>) -> KafkaPublisher
Expand description

start_threadpool

Arguments

  • label - optional tracking log label (ktp is the default if not set)

Examples

use kafka_threadpool::start_threadpool::start_threadpool;
let log_label = "ktp";
let kafka_publisher = start_threadpool(log_label).await;