src/rdkafka_broker.c
static void rd_kafka_broker_feature_enable (rd_kafka_broker_t *rkb,
					    int features) {
	if (features & rkb->rkb_features)
		return;

	rkb->rkb_features |= features;
	rd_rkb_dbg(rkb, BROKER | RD_KAFKA_DBG_PROTOCOL | RD_KAFKA_DBG_FEATURE,
		   "FEATURE",
		   "Updated enabled protocol features +%s to %s",
		   rd_kafka_features2str(features),
		   rd_kafka_features2str(rkb->rkb_features));
}
/**
 * @brief Enable protocol feature(s) for the current broker.
 *
 * Locality: broker thread
 */
@brief Enable protocol feature(s) for the current broker.
Locality: broker thread
@brief Enable protocol feature ( s ) for the current broker . Locality : broker thread
static void rd_kafka_broker_feature_enable (rd_kafka_broker_t *rkb,
					    int features) {
	if (features & rkb->rkb_features)
		return;
	rkb->rkb_features |= features;
	rd_rkb_dbg(rkb, BROKER | RD_KAFKA_DBG_PROTOCOL | RD_KAFKA_DBG_FEATURE,
		   "FEATURE",
		   "Updated enabled protocol features +%s to %s",
		   rd_kafka_features2str(features),
		   rd_kafka_features2str(rkb->rkb_features));
}
static void rd_kafka_broker_feature_enable ( rd_kafka_broker_t * rkb , int features ) { if ( features & rkb -> rkb_features ) return ; rkb -> rkb_features |= features ; rd_rkb_dbg ( rkb , BROKER | RD_KAFKA_DBG_PROTOCOL | RD_KAFKA_DBG_FEATURE , " " , " " , rd_kafka_features2str ( features ) , rd_kafka_features2str ( rkb -> rkb_features ) ) ; }
@brief Enable protocol feature(s) for the current broker.
@brief Enable protocol feature ( s ) for the current broker .