Home
last modified time | relevance | path

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

/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0117-mock_errors.c140 c1 = test_create_consumer("mygroup", test_rebalance_cb,
144 c2 = test_create_consumer("mygroup", test_rebalance_cb,
H A D0106-cgrp_sess_timeout.c258 c = test_create_consumer(groupid, test_rebalance_cb, conf, NULL); in do_test_commit_on_lost()
H A Dtest.h460 void test_rebalance_cb (rd_kafka_t *rk,
H A Dtest.c2329 void test_rebalance_cb (rd_kafka_t *rk, in test_rebalance_cb() function
/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0117-mock_errors.c135 c1 = test_create_consumer("mygroup", test_rebalance_cb, in do_test_offset_commit_error_during_rebalance()
138 c2 = test_create_consumer("mygroup", test_rebalance_cb, in do_test_offset_commit_error_during_rebalance()
H A D0106-cgrp_sess_timeout.c258 c = test_create_consumer(groupid, test_rebalance_cb, conf, NULL); in do_test_commit_on_lost()
H A D0045-subscribe_update.c392 rk = test_create_consumer("mygroup", test_rebalance_cb, conf, NULL); in do_test_regex_many_mock()
H A Dtest.h464 void test_rebalance_cb (rd_kafka_t *rk,
H A Dtest.c2364 void test_rebalance_cb (rd_kafka_t *rk, in test_rebalance_cb() function