| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_complex_consumer_example.cpp | 66 static bool exit_eof = false; variable
218 if (exit_eof && ++eof_cnt == partition_cnt) { in msg_consume()
277 exit_eof = true; in main()
363 if (exit_eof) { in main()
|
| H A D | rdkafka_complex_consumer_example.c | 52 static int exit_eof = 0; variable
123 if (exit_eof && --wait_eof == 0) { in msg_consume()
336 exit_eof = 1; in main()
|
| H A D | rdkafka_example.c | 52 static int exit_eof = 0; variable
135 if (exit_eof) in msg_consume()
368 exit_eof = 1; in main()
|
| H A D | rdkafka_example.cpp | 120 static bool exit_eof = false; variable
239 if (exit_eof) { in msg_consume()
330 exit_eof = true; in main()
|
| H A D | rdkafka_performance.c | 66 static int exit_eof = 0; variable
271 if (exit_eof && ++eof_cnt == partition_cnt) in msg_consume()
348 if (exit_eof && in rebalance_cb()
979 exit_eof = 1; in main()
|
| H A D | kafkatest_verifiable_client.cpp | 64 static bool exit_eof = false; variable
496 if (exit_eof) { in msg_consume()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_complex_consumer_example.cpp | 66 static bool exit_eof = false;
218 if (exit_eof && ++eof_cnt == partition_cnt) {
277 exit_eof = true;
363 if (exit_eof) {
|
| H A D | rdkafka_complex_consumer_example.c | 52 static int exit_eof = 0; variable
123 if (exit_eof && --wait_eof == 0) { in msg_consume()
336 exit_eof = 1; in main()
|
| H A D | rdkafka_example.c | 52 static int exit_eof = 0; variable
135 if (exit_eof) in msg_consume()
368 exit_eof = 1; in main()
|
| H A D | rdkafka_example.cpp | 120 static bool exit_eof = false; variable
239 if (exit_eof) { in msg_consume()
330 exit_eof = true; in main()
|
| H A D | rdkafka_performance.c | 66 static int exit_eof = 0; variable
271 if (exit_eof && ++eof_cnt == partition_cnt) in msg_consume()
348 if (exit_eof && in rebalance_cb()
979 exit_eof = 1; in main()
|
| H A D | kafkatest_verifiable_client.cpp | 64 static bool exit_eof = false; variable
496 if (exit_eof) { in msg_consume()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_complex_consumer_example.cpp | 65 static bool exit_eof = false; variable
195 if (exit_eof && ++eof_cnt == partition_cnt) { in msg_consume()
255 exit_eof = true; in main()
|
| H A D | rdkafka_complex_consumer_example.c | 52 static int exit_eof = 0; variable
123 if (exit_eof && --wait_eof == 0) { in msg_consume()
317 exit_eof = 1; in main()
|
| H A D | rdkafka_zookeeper_example.c | 56 static int exit_eof = 0; variable
135 if (exit_eof) in msg_consume()
381 exit_eof = 1; in main()
|
| H A D | rdkafka_example.c | 52 static int exit_eof = 0; variable
132 if (exit_eof) in msg_consume()
362 exit_eof = 1; in main()
|
| H A D | rdkafka_example.cpp | 120 static bool exit_eof = false; variable
239 if (exit_eof) { in msg_consume()
330 exit_eof = true; in main()
|
| H A D | rdkafka_performance.c | 66 static int exit_eof = 0; variable
271 if (exit_eof && ++eof_cnt == partition_cnt) in msg_consume()
960 exit_eof = 1; in main()
|
| H A D | kafkatest_verifiable_client.cpp | 64 static bool exit_eof = false; variable
496 if (exit_eof) { in msg_consume()
|
| /dports/devel/libserdes/libserdes-6.0.2/examples/ |
| H A D | serdes-kafka-avro-client.c | 32 static int exit_eof = 0; variable
103 if (exit_eof) in run_consumer()
|
| /dports/net/kcat/kcat-1.7.0/ |
| H A D | kcat.h | 135 int exit_eof; member
|
| H A D | kcat.c | 546 if (conf.mode != 'G' || !conf.exit_eof || in partition_not_eof()
577 if (conf.exit_eof) { in partition_at_eof()
581 } else if (conf.mode == 'G' && conf.exit_eof && conf.assignment) { in partition_at_eof()
1004 if (conf.exit_eof || conf.stopts) { in consumer_run()
2086 conf.exit_eof = 1; in argparse()
|