Home
last modified time | relevance | path

Searched refs:rd_kafkap_str_new (Results 1 – 20 of 20) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_assignor.c531 rkas->rkas_protocol_name = rd_kafkap_str_new(protocol_name, -1); in rd_kafka_assignor_add()
532 rkas->rkas_protocol_type = rd_kafkap_str_new(protocol_type, -1); in rd_kafka_assignor_add()
902 rd_kafkap_str_new(tests[i].members[im].name, in ut_assignors()
905 rd_kafkap_str_new(tests[i].members[im].name, in ut_assignors()
H A Drdkafka_proto.h294 rd_kafkap_str_t *rd_kafkap_str_new (const char *str, int len) { in rd_kafkap_str_new() function
330 return rd_kafkap_str_new(src->str, src->len); in rd_kafkap_str_copy()
H A Drdkafka.c2248 rk->rk_client_id = rd_kafkap_str_new(rk->rk_conf.client_id_str,-1); in rd_kafka_new()
2251 rk->rk_group_id = rd_kafkap_str_new(rk->rk_conf.group_id_str,-1); in rd_kafka_new()
2369 rd_kafkap_str_new(rk->rk_conf.eos.transactional_id, -1); in rd_kafka_new()
H A Drdkafka_topic.c329 rkt->rkt_topic = rd_kafkap_str_new(topic, -1); in rd_kafka_topic_new0()
H A Drdkafka_sticky_assignor.c2287 rkgm->rkgm_member_id = rd_kafkap_str_new(member_id, -1); in ut_init_member()
2288 rkgm->rkgm_group_instance_id = rd_kafkap_str_new(member_id, -1); in ut_init_member()
H A Drdkafka_conf.c1775 *kstr = rd_kafkap_str_new(istr, -1); in rd_kafka_anyconf_set_prop0()
1778 rd_kafkap_str_new(prop->sdef, -1) : NULL; in rd_kafka_anyconf_set_prop0()
H A Drdkafka_cgrp.c430 rd_kafkap_str_new(rk->rk_conf.group_instance_id, -1); in rd_kafka_cgrp_new()
5449 rkcg->rkcg_member_id = rd_kafkap_str_new(member_id, -1); in rd_kafka_cgrp_set_member_id()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_assignor.c531 rkas->rkas_protocol_name = rd_kafkap_str_new(protocol_name, -1); in rd_kafka_assignor_add()
532 rkas->rkas_protocol_type = rd_kafkap_str_new(protocol_type, -1); in rd_kafka_assignor_add()
902 rd_kafkap_str_new(tests[i].members[im].name, in ut_assignors()
905 rd_kafkap_str_new(tests[i].members[im].name, in ut_assignors()
H A Drdkafka_proto.h294 rd_kafkap_str_t *rd_kafkap_str_new (const char *str, int len) { in rd_kafkap_str_new() function
330 return rd_kafkap_str_new(src->str, src->len); in rd_kafkap_str_copy()
H A Drdkafka.c2247 rk->rk_client_id = rd_kafkap_str_new(rk->rk_conf.client_id_str,-1);
2250 rk->rk_group_id = rd_kafkap_str_new(rk->rk_conf.group_id_str,-1);
2368 rd_kafkap_str_new(rk->rk_conf.eos.transactional_id, -1);
H A Drdkafka_topic.c329 rkt->rkt_topic = rd_kafkap_str_new(topic, -1);
H A Drdkafka_conf.c1773 *kstr = rd_kafkap_str_new(istr, -1); in rd_kafka_anyconf_set_prop0()
1776 rd_kafkap_str_new(prop->sdef, -1) : NULL; in rd_kafka_anyconf_set_prop0()
H A Drdkafka_sticky_assignor.c2287 rkgm->rkgm_member_id = rd_kafkap_str_new(member_id, -1);
2288 rkgm->rkgm_group_instance_id = rd_kafkap_str_new(member_id, -1);
H A Drdkafka_cgrp.c367 rd_kafkap_str_new(rk->rk_conf.group_instance_id, -1); in rd_kafka_cgrp_new()
5187 rkcg->rkcg_member_id = rd_kafkap_str_new(member_id, -1); in rd_kafka_cgrp_set_member_id()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_proto.h288 rd_kafkap_str_t *rd_kafkap_str_new (const char *str, int len) { in rd_kafkap_str_new() function
324 return rd_kafkap_str_new(src->str, src->len); in rd_kafkap_str_copy()
H A Drdkafka_assignor.c462 rkas->rkas_protocol_name = rd_kafkap_str_new(protocol_name, -1); in rd_kafka_assignor_add()
463 rkas->rkas_protocol_type = rd_kafkap_str_new(protocol_type, -1); in rd_kafka_assignor_add()
H A Drdkafka.c2133 rk->rk_client_id = rd_kafkap_str_new(rk->rk_conf.client_id_str,-1); in rd_kafka_new()
2136 rk->rk_group_id = rd_kafkap_str_new(rk->rk_conf.group_id_str,-1); in rd_kafka_new()
2246 rd_kafkap_str_new(rk->rk_conf.eos.transactional_id, in rd_kafka_new()
H A Drdkafka_conf.c1573 *kstr = rd_kafkap_str_new(istr, -1); in rd_kafka_anyconf_set_prop0()
1576 rd_kafkap_str_new(prop->sdef, -1) : NULL; in rd_kafka_anyconf_set_prop0()
H A Drdkafka_topic.c279 rkt->rkt_topic = rd_kafkap_str_new(topic, -1); in rd_kafka_topic_new0()
H A Drdkafka_cgrp.c237 rd_kafkap_str_new(rk->rk_conf.group_instance_id, -1); in rd_kafka_cgrp_new()
3475 rkcg->rkcg_member_id = rd_kafkap_str_new(member_id, -1); in rd_kafka_cgrp_set_member_id()