plugins/out_kafka/librdkafka-1.5.0/src/rdkafka_assignor.c
int
rd_kafka_group_member_find_subscription (rd_kafka_t *rk,
					 const rd_kafka_group_member_t *rkgm,
					 const char *topic) {
	int i;

	/* Match against member's subscription. */
        for (i = 0 ; i < rkgm->rkgm_subscription->cnt ; i++) {
                const rd_kafka_topic_partition_t *rktpar =
                        &rkgm->rkgm_subscription->elems[i];

		if (rd_kafka_topic_partition_match(rk, rkgm, rktpar,
						   topic, NULL))
			return 1;
	}

	return 0;
}
/**
 * Returns true if member subscribes to topic, else false.
 */
Returns true if member subscribes to topic, else false.
Returns true if member subscribes to topic else false .
int
rd_kafka_group_member_find_subscription (rd_kafka_t *rk,
					 const rd_kafka_group_member_t *rkgm,
					 const char *topic) {
	int i;
        for (i = 0 ; i < rkgm->rkgm_subscription->cnt ; i++) {
                const rd_kafka_topic_partition_t *rktpar =
                        &rkgm->rkgm_subscription->elems[i];
		if (rd_kafka_topic_partition_match(rk, rkgm, rktpar,
						   topic, NULL))
			return 1;
	}
	return 0;
}
int rd_kafka_group_member_find_subscription ( rd_kafka_t * rk , const rd_kafka_group_member_t * rkgm , const char * topic ) { int i ; for ( i = 0 ; i < rkgm -> rkgm_subscription -> cnt ; i ++ ) { const rd_kafka_topic_partition_t * rktpar = & rkgm -> rkgm_subscription -> elems [ i ] ; if ( rd_kafka_topic_partition_match ( rk , rkgm , rktpar , topic , NULL ) ) return 1 ; } return 0 ; }
Returns true if member subscribes to topic, else false.
Returns true if member subscribes to topic else false .
/* Match against member's subscription. */