src/rdkafka_broker.c
void rd_kafka_broker_schedule_connection (rd_kafka_broker_t *rkb) {
        rd_kafka_op_t *rko;

        rko = rd_kafka_op_new(RD_KAFKA_OP_CONNECT);
        rd_kafka_op_set_prio(rko, RD_KAFKA_PRIO_FLASH);
        rd_kafka_q_enq(rkb->rkb_ops, rko);
}
/**
 * @brief Schedule connection for \p rkb.
 *        Will trigger disconnection for logical brokers whose nodename
 *        was changed.
 *
 * @locality any
 * @locks none
 */
@brief Schedule connection for \p rkb.
Will trigger disconnection for logical brokers whose nodename
was changed.

@locality any
@locks none
@brief Schedule connection for \ p rkb . Will trigger disconnection for logical brokers whose nodename was changed . @locality any @locks none
void rd_kafka_broker_schedule_connection (rd_kafka_broker_t *rkb) {
        rd_kafka_op_t *rko;
        rko = rd_kafka_op_new(RD_KAFKA_OP_CONNECT);
        rd_kafka_op_set_prio(rko, RD_KAFKA_PRIO_FLASH);
        rd_kafka_q_enq(rkb->rkb_ops, rko);
}
void rd_kafka_broker_schedule_connection ( rd_kafka_broker_t * rkb ) { rd_kafka_op_t * rko ; rko = rd_kafka_op_new ( RD_KAFKA_OP_CONNECT ) ; rd_kafka_op_set_prio ( rko , RD_KAFKA_PRIO_FLASH ) ; rd_kafka_q_enq ( rkb -> rkb_ops , rko ) ; }
@brief Schedule connection for \p rkb.
@brief Schedule connection for \ p rkb .