Lines Matching refs:rd_kafka_resp_err_t
132 rd_kafka_resp_err_t exp_dr_err; /* Expected error in test_dr_cb */
136 rd_kafka_resp_err_t produce_sync_err; /**< DR error */
154 int (*is_fatal_cb) (rd_kafka_t *rk, rd_kafka_resp_err_t err,
341 rd_kafka_resp_err_t err, int msgnum);
437 rd_kafka_resp_err_t test_produce_sync (rd_kafka_t *rk, rd_kafka_topic_t *rkt,
447 rd_kafka_resp_err_t err,
506 int timeout_ms, rd_kafka_resp_err_t err);
540 rd_kafka_resp_err_t test_auto_create_topic_rkt (rd_kafka_t *rk,
543 rd_kafka_resp_err_t test_auto_create_topic (rd_kafka_t *rk, const char *name,
590 rd_kafka_resp_err_t
596 rd_kafka_resp_err_t
602 rd_kafka_resp_err_t
609 rd_kafka_resp_err_t
615 rd_kafka_resp_err_t
621 rd_kafka_resp_err_t test_delete_all_test_topics (int timeout_ms);
640 rd_kafka_resp_err_t _err; \