Home
last modified time | relevance | path

Searched refs:RD_KAFKA_RESP_ERR__STATE (Results 1 – 25 of 28) sorted by relevance

12

/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0103-transactions.c565 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
573 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
627 RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
640 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
735 RD_KAFKA_RESP_ERR__STATE /* FIXME ? */, in do_test_fenced_txn()
738 rd_kafka_err2name(RD_KAFKA_RESP_ERR__STATE), in do_test_fenced_txn()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0103-transactions.c588 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
597 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
654 RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
667 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_txnmgr.c98 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_require_states0()
769 err = RD_KAFKA_RESP_ERR__STATE; in rd_kafka_txn_register_partitions()
1057 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_curr_api_req()
1534 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_txn_send_TxnOffsetCommitRequest()
1771 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_send_offsets_to_transaction()
2017 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_commit_transaction()
2229 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_abort_transaction()
H A Drdkafka_sasl_oauthbearer.c367 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token0()
460 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token_failure0()
H A Drdkafka_msg.c67 rd_kafka_set_last_error(RD_KAFKA_RESP_ERR__STATE, ENOEXEC); in rd_kafka_check_produce()
69 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_check_produce()
H A Drdkafka.h319 RD_KAFKA_RESP_ERR__STATE = -172, enumerator
H A Drdkafka_partition.c1750 err = RD_KAFKA_RESP_ERR__STATE; in rd_kafka_toppar_seek()
/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0103-transactions.c588 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
597 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
654 RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
667 TEST_ASSERT(rd_kafka_error_code(error) == RD_KAFKA_RESP_ERR__STATE, in do_test_misuse_txn()
H A D0105-transactions_mock.c2714 TEST_ASSERT(err == RD_KAFKA_RESP_ERR__STATE, in do_test_out_of_order_seq()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/
H A Dhelpers.rs38 RD_KAFKA_RESP_ERR__STATE => State, in rd_kafka_resp_err_t_to_rdkafka_error()
H A Dbindings.rs142 RD_KAFKA_RESP_ERR__STATE = -172, enumerator
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_txnmgr.c127 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_require_states0()
1218 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_curr_api_req()
1702 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_txn_send_TxnOffsetCommitRequest()
1711 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_txn_send_TxnOffsetCommitRequest()
2006 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_send_offsets_to_transaction()
2382 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_commit_transaction()
2739 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_txn_op_abort_transaction()
H A Drdkafka_sasl_oauthbearer.c367 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token0()
460 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token_failure0()
H A Drdkafka_msg.c93 rd_kafka_set_last_error(RD_KAFKA_RESP_ERR__STATE, ENOEXEC); in rd_kafka_check_produce()
98 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_check_produce()
104 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_check_produce()
H A Drdkafka.h330 RD_KAFKA_RESP_ERR__STATE = -172, enumerator
H A Drdkafka_cgrp.c4887 error = rd_kafka_error_new(RD_KAFKA_RESP_ERR__STATE, in rd_kafka_cgrp_handle_assign_op()
4898 error = rd_kafka_error_new(RD_KAFKA_RESP_ERR__STATE, in rd_kafka_cgrp_handle_assign_op()
H A Drdkafka_partition.c1783 err = RD_KAFKA_RESP_ERR__STATE; in rd_kafka_toppar_seek()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_txnmgr.c127 RD_KAFKA_RESP_ERR__STATE,
1218 RD_KAFKA_RESP_ERR__STATE,
1702 return RD_KAFKA_RESP_ERR__STATE;
1711 return RD_KAFKA_RESP_ERR__STATE;
1999 RD_KAFKA_RESP_ERR__STATE,
2375 RD_KAFKA_RESP_ERR__STATE,
2732 RD_KAFKA_RESP_ERR__STATE,
H A Drdkafka_sasl_oauthbearer.c367 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token0()
460 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_oauthbearer_set_token_failure0()
H A Drdkafka_msg.c93 rd_kafka_set_last_error(RD_KAFKA_RESP_ERR__STATE, ENOEXEC); in rd_kafka_check_produce()
98 RD_KAFKA_RESP_ERR__STATE, in rd_kafka_check_produce()
104 return RD_KAFKA_RESP_ERR__STATE; in rd_kafka_check_produce()
H A Drdkafka.h330 RD_KAFKA_RESP_ERR__STATE = -172, enumerator
H A Drdkafka_cgrp.c4628 error = rd_kafka_error_new(RD_KAFKA_RESP_ERR__STATE, in rd_kafka_cgrp_handle_assign_op()
4639 error = rd_kafka_error_new(RD_KAFKA_RESP_ERR__STATE, in rd_kafka_cgrp_handle_assign_op()
H A Drdkafka_partition.c1768 err = RD_KAFKA_RESP_ERR__STATE; in rd_kafka_toppar_seek()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/
H A DCHANGELOG.md306 * The transactional producer API would return `RD_KAFKA_RESP_ERR__STATE`
/dports/net/librdkafka/librdkafka-1.8.2/
H A DCHANGELOG.md452 * The transactional producer API would return `RD_KAFKA_RESP_ERR__STATE`

12