Lines Matching refs:rk_type

845         if (rk->rk_type == RD_KAFKA_CONSUMER && rk->rk_cgrp)  in rd_kafka_set_fatal_error0()
864         if (rk->rk_type == RD_KAFKA_PRODUCER) {  in rd_kafka_set_fatal_error0()
940         if (rk->rk_type == RD_KAFKA_PRODUCER) {  in rd_kafka_destroy_final()
1419                    rk->rk_type == RD_KAFKA_PRODUCER ?  in rd_kafka_stats_emit_toppar()
1505                 if (filter[rkb->rkb_rk->rk_type][i] || filter[2][i])  in rd_kafka_stats_emit_broker_reqs()
1561                    rd_kafka_type2str(rk->rk_type),  in rd_kafka_stats_emit_all()
1839         if (rk->rk_type == RD_KAFKA_CONSUMER && rk->rk_cgrp &&  in rd_kafka_metadata_refresh_cb()
2033 	rk->rk_type = type;  in rd_kafka_new()
2129                     rk->rk_conf.client_id_str, rd_kafka_type2str(rk->rk_type),  in rd_kafka_new()
2147         if (rk->rk_type == RD_KAFKA_PRODUCER) {  in rd_kafka_new()
3895         return rk->rk_type;  in rd_kafka_type()
4018 	if (rk->rk_type != RD_KAFKA_PRODUCER)  in rd_kafka_flush()
4075         if (rk->rk_type != RD_KAFKA_PRODUCER)  in rd_kafka_purge()