Home
last modified time | relevance | path

Searched refs:_consumer_t (Results 1 – 3 of 3) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0102-static_group_rebalance.c49 } _consumer_t; typedef
56 _consumer_t *c, int64_t start, in static_member_wait_rebalance0()
102 _consumer_t *c = opaque; in rebalance_cb()
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 D0102-static_group_rebalance.c49 } _consumer_t; typedef
56 _consumer_t *c, int64_t start, in static_member_wait_rebalance0()
99 _consumer_t *c = opaque; in rebalance_cb()
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 D0102-static_group_rebalance.c49 } _consumer_t; typedef
56 _consumer_t *c, int64_t start, in static_member_wait_rebalance0()
102 _consumer_t *c = opaque; in rebalance_cb()
148 _consumer_t c[_CONSUMER_CNT] = RD_ZERO_INIT; in do_test_static_group_rebalance()