Home
last modified time | relevance | path

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

/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0091-max_poll_interval_timeout.c115 #define _CONSUMER_CNT 2 macro
119 struct _consumer c[_CONSUMER_CNT] = RD_ZERO_INIT; in do_test_with_subscribe()
131 test_produce_msgs_easy(topic, testid, -1, msgcnt * _CONSUMER_CNT * 2); in do_test_with_subscribe()
H A D0093-holb.c105 #define _CONSUMER_CNT 2 macro
110 struct _consumer c[_CONSUMER_CNT] = RD_ZERO_INIT; in main_0093_holb_consumer()
H A D0102-static_group_rebalance.c39 #define _CONSUMER_CNT 2 macro
148 _consumer_t c[_CONSUMER_CNT] = RD_ZERO_INIT; in do_test_static_group_rebalance()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0091-max_poll_interval_timeout.c115 #define _CONSUMER_CNT 2 macro
119 struct _consumer c[_CONSUMER_CNT] = RD_ZERO_INIT; in do_test_with_subscribe()
131 test_produce_msgs_easy(topic, testid, -1, msgcnt * _CONSUMER_CNT * 2); in do_test_with_subscribe()
H A D0093-holb.c105 #define _CONSUMER_CNT 2 macro
110 struct _consumer c[_CONSUMER_CNT] = RD_ZERO_INIT; in main_0093_holb_consumer()
H A D0102-static_group_rebalance.c39 #define _CONSUMER_CNT 2 macro
145 _consumer_t c[_CONSUMER_CNT] = RD_ZERO_INIT; in do_test_static_group_rebalance()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0091-max_poll_interval_timeout.c115 #define _CONSUMER_CNT 2 macro
119 struct _consumer c[_CONSUMER_CNT] = RD_ZERO_INIT; in do_test_with_subscribe()
131 test_produce_msgs_easy(topic, testid, -1, msgcnt * _CONSUMER_CNT * 2); in do_test_with_subscribe()
H A D0093-holb.c105 #define _CONSUMER_CNT 2 macro
110 struct _consumer c[_CONSUMER_CNT] = RD_ZERO_INIT; in main_0093_holb_consumer()
H A D0102-static_group_rebalance.c39 #define _CONSUMER_CNT 2 macro
148 _consumer_t c[_CONSUMER_CNT] = RD_ZERO_INIT; in do_test_static_group_rebalance()