Searched refs:msgs_dr_err (Results 1 – 3 of 3) sorted by relevance
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_performance.c | 104 uint64_t msgs_dr_err; member
196 cnt.msgs_dr_err++; in msg_delivered()
212 (cnt.msgs_dr_err < 50 || in msg_delivered()
213 !(cnt.msgs_dr_err % (dispintvl / 1000)))) || in msg_delivered()
288 cnt.msgs_dr_err++; in msg_consume()
569 COL_PR64("dr_err", cnt.msgs_dr_err); in print_stats()
593 cnt.msgs_dr_ok, cnt.last_offset, cnt.msgs_dr_err, in print_stats()
634 COL_PR64("rx_err", cnt.msgs_dr_err); in print_stats()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_performance.c | 104 uint64_t msgs_dr_err; member
196 cnt.msgs_dr_err++; in msg_delivered()
212 (cnt.msgs_dr_err < 50 || in msg_delivered()
213 !(cnt.msgs_dr_err % (dispintvl / 1000)))) || in msg_delivered()
288 cnt.msgs_dr_err++; in msg_consume()
536 COL_PR64("dr_err", cnt.msgs_dr_err); in print_stats()
560 cnt.msgs_dr_ok, cnt.last_offset, cnt.msgs_dr_err, in print_stats()
601 COL_PR64("rx_err", cnt.msgs_dr_err); in print_stats()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_performance.c | 104 uint64_t msgs_dr_err; member
196 cnt.msgs_dr_err++; in msg_delivered()
212 (cnt.msgs_dr_err < 50 || in msg_delivered()
213 !(cnt.msgs_dr_err % (dispintvl / 1000)))) || in msg_delivered()
288 cnt.msgs_dr_err++; in msg_consume()
569 COL_PR64("dr_err", cnt.msgs_dr_err); in print_stats()
593 cnt.msgs_dr_ok, cnt.last_offset, cnt.msgs_dr_err, in print_stats()
634 COL_PR64("rx_err", cnt.msgs_dr_err); in print_stats()
|