plugins/out_kafka/librdkafka-1.5.0/src/rdkafka_assignor.c
rd_kafka_assignor_t *
rd_kafka_assignor_find (rd_kafka_t *rk, const char *protocol) {
        return (rd_kafka_assignor_t *)
                rd_list_find(&rk->rk_conf.partition_assignors, protocol,
                             rd_kafka_assignor_cmp_str);
}
/**
 * Find assignor by protocol name.
 *
 * Locality: any
 * Locks: none
 */
Find assignor by protocol name.
Locality: any
Locks: none
Find assignor by protocol name . Locality : any Locks : none
rd_kafka_assignor_t *
rd_kafka_assignor_find (rd_kafka_t *rk, const char *protocol) {
        return (rd_kafka_assignor_t *)
                rd_list_find(&rk->rk_conf.partition_assignors, protocol,
                             rd_kafka_assignor_cmp_str);
}
rd_kafka_assignor_t * rd_kafka_assignor_find ( rd_kafka_t * rk , const char * protocol ) { return ( rd_kafka_assignor_t * ) rd_list_find ( & rk -> rk_conf . partition_assignors , protocol , rd_kafka_assignor_cmp_str ) ; }
Find assignor by protocol name.
Find assignor by protocol name .