Macro kafka_warn 

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

Log at WARN level with a LogContext prefix.