Function thread_process_messages_handler 

pub async fn thread_process_messages_handler(
    cur_thread_num: u8,
    config: KafkaClientConfig,
    lockable_work_vec: Arc<Mutex<Vec<KafkaPublishMessage>>>,
)

thread_process_messages_handler

Each tokio-spawned thread calls this method

Arguments

• cur_thread_num - thread counter assigned by [start_threads_from_config]
• config - initialized KafkaClientConfig for this thread
• lockable_work_vec - shared work vec of KafkaPublishMessage messages to process within a lockable Arc<Mutex<lockable_work_vec>> thread-safe object