Searched defs:consumer_group_rebalance_cb (Results 1 – 5 of 5) sorted by relevance
358 consumer_group_rebalance_cb (rd_kafka_t *consumer, in consumer_group_rebalance_cb() function
366 consumer_group_rebalance_cb (rd_kafka_t *rk, in consumer_group_rebalance_cb() function
361 consumer_group_rebalance_cb (rd_kafka_t *rk, in consumer_group_rebalance_cb() function
358 return 2; in consumer_group_rebalance_cb()359 }360 361 362 /*363 ** Commit the current transaction.