Method handle_message

examples/kafka_processor_complex.rs:110–123

(&mut self, msg: OwnedDeliveryResult)

    async fn terminate(&mut self) {}

    async fn handle_message(&mut self, msg: OwnedDeliveryResult) ->  ProcResult<()> {
        
        match msg {
            Some((partition, offset)) => {

            }
            Err((kafka_err, msg)) => {

                // TODO: Push to dead letter or requeue
            }
        }

        ProcResult::Continue
    } 
}