Searched refs:rd_kafka_buf_read_ptr (Results 1 – 9 of 9) sorted by relevance
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_msg.c | 1240 rd_kafka_buf_read_ptr(rkbuf, &Key, (size_t)KeyLen); in rd_kafka_msg_headers_parse() 1246 rd_kafka_buf_read_ptr(rkbuf, &Value, (size_t)ValueLen); in rd_kafka_msg_headers_parse()
|
H A D | rdkafka_buf.h | 454 #define rd_kafka_buf_read_ptr(rkbuf,ptr,size) do { \ macro
|
H A D | rdkafka_msgset_reader.c | 884 rd_kafka_buf_read_ptr(rkbuf, &hdr.Headers.data, hdr.Headers.len); in rd_kafka_msgset_reader_msg_v2()
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_msg.c | 1499 rd_kafka_buf_read_ptr(rkbuf, &Key, (size_t)KeyLen); in rd_kafka_msg_headers_parse() 1505 rd_kafka_buf_read_ptr(rkbuf, &Value, (size_t)ValueLen); in rd_kafka_msg_headers_parse()
|
H A D | rdkafka_buf.h | 696 #define rd_kafka_buf_read_ptr(rkbuf,ptr,size) do { \ macro
|
H A D | rdkafka_msgset_reader.c | 896 rd_kafka_buf_read_ptr(rkbuf, &hdr.Headers.data, hdr.Headers.len); in rd_kafka_msgset_reader_msg_v2()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_msg.c | 1499 rd_kafka_buf_read_ptr(rkbuf, &Key, (size_t)KeyLen); in rd_kafka_msg_headers_parse() 1505 rd_kafka_buf_read_ptr(rkbuf, &Value, (size_t)ValueLen); in rd_kafka_msg_headers_parse()
|
H A D | rdkafka_buf.h | 643 #define rd_kafka_buf_read_ptr(rkbuf,ptr,size) do { \
|
H A D | rdkafka_msgset_reader.c | 896 rd_kafka_buf_read_ptr(rkbuf, &hdr.Headers.data, hdr.Headers.len); in rd_kafka_msgset_reader_msg_v2()
|