src/rdkafka.c
static void rd_kafka_1s_tmr_cb (rd_kafka_timers_t *rkts, void *arg) {
        rd_kafka_t *rk = rkts->rkts_rk;

        /* Scan topic state, message timeouts, etc. */
        rd_kafka_topic_scan_all(rk, rd_clock());

        /* Sparse connections:
         * try to maintain at least one connection to the cluster. */
        if (rk->rk_conf.sparse_connections &&
            rd_atomic32_get(&rk->rk_broker_up_cnt) == 0)
                rd_kafka_connect_any(rk, "no cluster connection");

}
/**
 * @brief 1 second generic timer.
 *
 * @locality rdkafka main thread
 * @locks none
 */
@brief 1 second generic timer.
@locality rdkafka main thread
@locks none
@brief 1 second generic timer . @locality rdkafka main thread @locks none
static void rd_kafka_1s_tmr_cb (rd_kafka_timers_t *rkts, void *arg) {
        rd_kafka_t *rk = rkts->rkts_rk;
        rd_kafka_topic_scan_all(rk, rd_clock());
        if (rk->rk_conf.sparse_connections &&
            rd_atomic32_get(&rk->rk_broker_up_cnt) == 0)
                rd_kafka_connect_any(rk, "no cluster connection");
}
static void rd_kafka_1s_tmr_cb ( rd_kafka_timers_t * rkts , void * arg ) { rd_kafka_t * rk = rkts -> rkts_rk ; rd_kafka_topic_scan_all ( rk , rd_clock ( ) ) ; if ( rk -> rk_conf . sparse_connections && rd_atomic32_get ( & rk -> rk_broker_up_cnt ) == 0 ) rd_kafka_connect_any ( rk , " " ) ; }
@brief 1 second generic timer.
@brief 1 second generic timer .
/* Scan topic state, message timeouts, etc. */ /* Sparse connections:
         * try to maintain at least one connection to the cluster. */