Module kafka_threadpool::thread_process_messages_handler

source · [−]
Expand description

Handler that each tokio-spawned thread uses to process all messages. This function is the thread context state machine.

Functions

thread_process_messages_handler
thread_process_messages_handler