/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_assignor.c | 531 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 D | rdkafka_proto.h | 294 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 D | rdkafka.c | 2248 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 D | rdkafka_topic.c | 329 rkt->rkt_topic = rd_kafkap_str_new(topic, -1); in rd_kafka_topic_new0()
|
H A D | rdkafka_sticky_assignor.c | 2287 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 D | rdkafka_conf.c | 1775 *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 D | rdkafka_cgrp.c | 430 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 D | rdkafka_assignor.c | 531 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 D | rdkafka_proto.h | 294 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 D | rdkafka.c | 2247 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 D | rdkafka_topic.c | 329 rkt->rkt_topic = rd_kafkap_str_new(topic, -1);
|
H A D | rdkafka_conf.c | 1773 *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 D | rdkafka_sticky_assignor.c | 2287 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 D | rdkafka_cgrp.c | 367 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 D | rdkafka_proto.h | 288 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 D | rdkafka_assignor.c | 462 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 D | rdkafka.c | 2133 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 D | rdkafka_conf.c | 1573 *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 D | rdkafka_topic.c | 279 rkt->rkt_topic = rd_kafkap_str_new(topic, -1); in rd_kafka_topic_new0()
|
H A D | rdkafka_cgrp.c | 237 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()
|