fn error(&self, error: rdkafka::error::KafkaError, reason: &str) {
        // Allow error to overwrite value irrespective of other conditions
        // (i.e. logging).
        *self.error.lock().expect("lock poisoned") = Some(reason.to_string());
        error!("librdkafka: {}: {}", error, reason);
    }
// Refer to the comment on the `log` callback.
Refer to the comment on the `log` callback.
Refer to the comment on the ` log ` callback .
fn error(&self, error: rdkafka::error::KafkaError, reason: &str) {
        // Allow error to overwrite value irrespective of other conditions
        // (i.e. logging).
        *self.error.lock().expect("lock poisoned") = Some(reason.to_string());
        error!("librdkafka: {}: {}", error, reason);
    }
fn error ( & self , error : rdkafka :: error :: KafkaError , reason : & str ) { // Allow error to overwrite value irrespective of other conditions // (i.e. logging). * self . error . lock ( ) . expect ( " " ) = Some ( reason . to_string ( ) ) ; error ! ( " " error reason ) ; }
Refer to the comment on the `log` callback.
Refer to the comment on the ` log ` callback .
&self
error
rdkafka::error::KafkaError
reason
&str
&self
error
rdkafka::error::KafkaError
reason
&str