Home
last modified time | relevance | path

Searched refs:RD_KAFKA_PURGE_F_ABORT_TXN (Results 1 – 9 of 9) sorted by relevance

/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_int.h774 #define RD_KAFKA_PURGE_F_ABORT_TXN 0x100 /**< Internal flag used when macro
H A Drdkafka_txnmgr.c335 RD_KAFKA_PURGE_F_ABORT_TXN | in rd_kafka_txn_set_abortable_error()
2310 RD_KAFKA_PURGE_F_ABORT_TXN); in rd_kafka_abort_transaction()
H A Drdkafka_partition.c3758 if (purge_flags & RD_KAFKA_PURGE_F_ABORT_TXN) { in rd_kafka_toppar_handle_purge_queues()
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_int.h819 #define RD_KAFKA_PURGE_F_ABORT_TXN 0x100 /**< Internal flag used when macro
H A Drdkafka_txnmgr.c378 RD_KAFKA_PURGE_F_ABORT_TXN | in rd_kafka_txn_set_abortable_error0()
2852 RD_KAFKA_PURGE_F_ABORT_TXN); in rd_kafka_abort_transaction()
H A Drdkafka_partition.c4319 if (cnt > 0 && purge_flags & RD_KAFKA_PURGE_F_ABORT_TXN) { in rd_kafka_toppar_purge_queues()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_int.h818 #define RD_KAFKA_PURGE_F_ABORT_TXN 0x100 /**< Internal flag used when macro
H A Drdkafka_txnmgr.c378 RD_KAFKA_PURGE_F_ABORT_TXN |
2845 RD_KAFKA_PURGE_F_ABORT_TXN);
H A Drdkafka_partition.c4304 if (cnt > 0 && purge_flags & RD_KAFKA_PURGE_F_ABORT_TXN) { in rd_kafka_toppar_purge_queues()