src/rdkafka_broker.c
static void rd_kafka_broker_fetch_backoff (rd_kafka_broker_t *rkb,
                                           rd_kafka_resp_err_t err) {
        int backoff_ms = rkb->rkb_rk->rk_conf.fetch_error_backoff_ms;
        rkb->rkb_ts_fetch_backoff = rd_clock() + (backoff_ms * 1000);
        rd_rkb_dbg(rkb, FETCH, "BACKOFF",
                   "Fetch backoff for %dms: %s",
                   backoff_ms, rd_kafka_err2str(err));
}
/**
 * Backoff the next Fetch request (due to error).
 */
Backoff the next Fetch request (due to error).
Backoff the next Fetch request ( due to error ) .
static void rd_kafka_broker_fetch_backoff (rd_kafka_broker_t *rkb,
                                           rd_kafka_resp_err_t err) {
        int backoff_ms = rkb->rkb_rk->rk_conf.fetch_error_backoff_ms;
        rkb->rkb_ts_fetch_backoff = rd_clock() + (backoff_ms * 1000);
        rd_rkb_dbg(rkb, FETCH, "BACKOFF",
                   "Fetch backoff for %dms: %s",
                   backoff_ms, rd_kafka_err2str(err));
}
static void rd_kafka_broker_fetch_backoff ( rd_kafka_broker_t * rkb , rd_kafka_resp_err_t err ) { int backoff_ms = rkb -> rkb_rk -> rk_conf . fetch_error_backoff_ms ; rkb -> rkb_ts_fetch_backoff = rd_clock ( ) + ( backoff_ms * 1000 ) ; rd_rkb_dbg ( rkb , FETCH , " " , " " , backoff_ms , rd_kafka_err2str ( err ) ) ; }
Backoff the next Fetch request (due to error).
Backoff the next Fetch request ( due to error ) .