Home
last modified time | relevance | path

Searched refs:rd_kafkap_bytes_new (Results 1 – 9 of 9) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_proto.h424 rd_kafkap_bytes_t *rd_kafkap_bytes_new (const char *bytes, int32_t len) { in rd_kafkap_bytes_new() function
456 return rd_kafkap_bytes_new( in rd_kafkap_bytes_copy()
H A Drdkafka_assignor.c163 kbytes = rd_kafkap_bytes_new(NULL, (int32_t)len); in rd_kafka_consumer_protocol_member_metadata_new()
H A Drdkafka_sticky_assignor.c1989 kbytes = rd_kafkap_bytes_new(NULL, (int32_t)len); in rd_kafka_sticky_assignor_get_metadata()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_proto.h418 rd_kafkap_bytes_t *rd_kafkap_bytes_new (const char *bytes, int32_t len) { in rd_kafkap_bytes_new() function
450 return rd_kafkap_bytes_new(src->data, src->len); in rd_kafkap_bytes_copy()
H A Drdkafka_assignor.c137 kbytes = rd_kafkap_bytes_new(NULL, (int32_t)len); in rd_kafka_consumer_protocol_member_metadata_new()
H A Drdkafka.c2123 rk->rk_null_bytes = rd_kafkap_bytes_new(NULL, 0); in rd_kafka_new()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_proto.h424 rd_kafkap_bytes_t *rd_kafkap_bytes_new (const char *bytes, int32_t len) { in rd_kafkap_bytes_new() function
456 return rd_kafkap_bytes_new( in rd_kafkap_bytes_copy()
H A Drdkafka_assignor.c163 kbytes = rd_kafkap_bytes_new(NULL, (int32_t)len); in rd_kafka_consumer_protocol_member_metadata_new()
H A Drdkafka_sticky_assignor.c1989 kbytes = rd_kafkap_bytes_new(NULL, (int32_t)len);