Searched refs:RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS (Results 1 – 14 of 14) sorted by relevance
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0105-transactions_mock.c | 277 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS); in do_test_txn_recoverable_errors() 660 { RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txn_endtxn_errors() 661 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txn_endtxn_errors() 1579 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txns_send_offsets_concurrent_is_retried() 1580 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txns_send_offsets_concurrent_is_retried() 1581 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txns_send_offsets_concurrent_is_retried() 1582 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txns_send_offsets_concurrent_is_retried() 1583 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txns_send_offsets_concurrent_is_retried() 1584 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS); in do_test_txns_send_offsets_concurrent_is_retried() 1923 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txn_coord_req_destroy() [all …]
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0105-transactions_mock.c | 277 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS); in do_test_txn_recoverable_errors() 660 { RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txn_endtxn_errors() 661 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txn_endtxn_errors() 1640 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txns_send_offsets_concurrent_is_retried() 1641 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txns_send_offsets_concurrent_is_retried() 1642 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txns_send_offsets_concurrent_is_retried() 1643 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txns_send_offsets_concurrent_is_retried() 1644 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txns_send_offsets_concurrent_is_retried() 1645 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS); in do_test_txns_send_offsets_concurrent_is_retried() 1984 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS, in do_test_txn_coord_req_destroy() [all …]
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
H A D | helpers.rs | 121 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS => ConcurrentTransactions, in rd_kafka_resp_err_t_to_rdkafka_error()
|
H A D | bindings.rs | 225 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS = 51, enumerator
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0105-transactions_mock.c | 178 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS); in do_test_txn_recoverable_errors()
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_txnmgr.c | 679 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS: in rd_kafka_txn_handle_AddPartitionsToTxn() 1600 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS: in rd_kafka_txn_handle_TxnOffsetCommit() 1873 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS: in rd_kafka_txn_handle_AddOffsetsToTxn() 2267 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS: in rd_kafka_txn_handle_EndTxn()
|
H A D | rdkafka.h | 517 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS = 51, enumerator
|
H A D | rdkafka.c | 614 _ERR_DESC(RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS,
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
H A D | rdkafka_txnmgr.c | 679 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS: 1600 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS: 1873 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS: 2260 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS:
|
H A D | rdkafka.h | 517 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS = 51, enumerator
|
H A D | rdkafka.c | 614 _ERR_DESC(RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS,
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
H A D | rdkafka_txnmgr.c | 600 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS: in rd_kafka_txn_handle_AddPartitionsToTxn() 1439 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS: in rd_kafka_txn_handle_TxnOffsetCommit() 1663 case RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS: in rd_kafka_txn_handle_AddOffsetsToTxn()
|
H A D | rdkafka.h | 500 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS = 51, enumerator
|
H A D | rdkafka.c | 619 _ERR_DESC(RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS,
|