Home
last modified time | relevance | path

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 D0105-transactions_mock.c277 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 D0105-transactions_mock.c277 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 Dhelpers.rs121 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS => ConcurrentTransactions, in rd_kafka_resp_err_t_to_rdkafka_error()
H A Dbindings.rs225 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 D0105-transactions_mock.c178 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS); in do_test_txn_recoverable_errors()
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_txnmgr.c679 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 Drdkafka.h517 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS = 51, enumerator
H A Drdkafka.c614 _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 Drdkafka_txnmgr.c679 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 Drdkafka.h517 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS = 51, enumerator
H A Drdkafka.c614 _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 Drdkafka_txnmgr.c600 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 Drdkafka.h500 RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS = 51, enumerator
H A Drdkafka.c619 _ERR_DESC(RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS,