src/rdkafka_broker.c
int rd_kafka_brokers_get_state_version (rd_kafka_t *rk) {
	int version;
	mtx_lock(&rk->rk_broker_state_change_lock);
	version = rk->rk_broker_state_change_version;
	mtx_unlock(&rk->rk_broker_state_change_lock);
	return version;
}
/**
 * @returns the current broker state change version.
 *          Pass this value to future rd_kafka_brokers_wait_state_change() calls
 *          to avoid the race condition where a state-change happens between
 *          an initial call to some API that fails and the sub-sequent
 *          .._wait_state_change() call.
 */
@returns the current broker state change version.
Pass this value to future rd_kafka_brokers_wait_state_change() calls
to avoid the race condition where a state-change happens between
an initial call to some API that fails and the sub-sequent
_wait_state_change() call.
@returns the current broker state change version . Pass this value to future rd_kafka_brokers_wait_state_change () calls to avoid the race condition where a state - change happens between an initial call to some API that fails and the sub - sequent _wait_state_change () call .
int rd_kafka_brokers_get_state_version (rd_kafka_t *rk) {
	int version;
	mtx_lock(&rk->rk_broker_state_change_lock);
	version = rk->rk_broker_state_change_version;
	mtx_unlock(&rk->rk_broker_state_change_lock);
	return version;
}
int rd_kafka_brokers_get_state_version ( rd_kafka_t * rk ) { int version ; mtx_lock ( & rk -> rk_broker_state_change_lock ) ; version = rk -> rk_broker_state_change_version ; mtx_unlock ( & rk -> rk_broker_state_change_lock ) ; return version ; }
@returns the current broker state change version.
@returns the current broker state change version .