Macro kafka_error 

macro_rules! kafka_error {
    ($ctx:expr, $($arg:tt)*) => { ... };
}

Log at ERROR level with a LogContext prefix.