Searched refs:rd_kafkap_bytes_new (Results 1 – 9 of 9) sorted by relevance
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_proto.h | 424 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 D | rdkafka_assignor.c | 163 kbytes = rd_kafkap_bytes_new(NULL, (int32_t)len); in rd_kafka_consumer_protocol_member_metadata_new()
|
H A D | rdkafka_sticky_assignor.c | 1989 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 D | rdkafka_proto.h | 418 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 D | rdkafka_assignor.c | 137 kbytes = rd_kafkap_bytes_new(NULL, (int32_t)len); in rd_kafka_consumer_protocol_member_metadata_new()
|
H A D | rdkafka.c | 2123 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 D | rdkafka_proto.h | 424 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 D | rdkafka_assignor.c | 163 kbytes = rd_kafkap_bytes_new(NULL, (int32_t)len); in rd_kafka_consumer_protocol_member_metadata_new()
|
H A D | rdkafka_sticky_assignor.c | 1989 kbytes = rd_kafkap_bytes_new(NULL, (int32_t)len);
|