Searched refs:rd_kafka_txn_coord_set (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 D | rdkafka_txnmgr.h | 150 rd_bool_t rd_kafka_txn_coord_set (rd_kafka_t *rk, rd_kafka_broker_t *rkb,
|
| H A D | rdkafka_txnmgr.c | 694 rd_kafka_txn_coord_set(rk, NULL, in rd_kafka_txn_handle_AddPartitionsToTxn()
1941 rd_kafka_txn_coord_set(rk, NULL, in rd_kafka_txn_handle_EndTxn()
2448 rd_kafka_txn_coord_set(rk, rkb, "FindCoordinator response"); in rd_kafka_txn_handle_FindCoordinator()
2486 rd_kafka_txn_coord_set(rk, NULL, in rd_kafka_txn_handle_FindCoordinator()
2574 rd_bool_t rd_kafka_txn_coord_set (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_txn_coord_set() function
|
| H A D | rdkafka_idempotence.c | 387 rd_kafka_txn_coord_set(rk, NULL, "%s", errstr); in rd_kafka_idemp_request_pid_failed()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_txnmgr.h | 167 rd_bool_t rd_kafka_txn_coord_set (rd_kafka_t *rk, rd_kafka_broker_t *rkb,
|
| H A D | rdkafka_txnmgr.c | 816 rd_kafka_txn_coord_set(rk, NULL, in rd_kafka_txn_handle_AddPartitionsToTxn()
2259 rd_kafka_txn_coord_set(rk, NULL, in rd_kafka_txn_handle_EndTxn()
3007 rd_kafka_txn_coord_set(rk, rkb, "FindCoordinator response"); in rd_kafka_txn_handle_FindCoordinator()
3046 rd_kafka_txn_coord_set(rk, NULL, in rd_kafka_txn_handle_FindCoordinator()
3138 rd_bool_t rd_kafka_txn_coord_set (rd_kafka_t *rk, rd_kafka_broker_t *rkb, in rd_kafka_txn_coord_set() function
|
| H A D | rdkafka_idempotence.c | 441 rd_kafka_txn_coord_set(rk, NULL, "%s", errstr); in rd_kafka_idemp_request_pid_failed()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_txnmgr.h | 167 rd_bool_t rd_kafka_txn_coord_set (rd_kafka_t *rk, rd_kafka_broker_t *rkb,
|
| H A D | rdkafka_txnmgr.c | 816 rd_kafka_txn_coord_set(rk, NULL,
2252 rd_kafka_txn_coord_set(rk, NULL,
2998 rd_kafka_txn_coord_set(rk, rkb, "FindCoordinator response");
3037 rd_kafka_txn_coord_set(rk, NULL,
3129 rd_bool_t rd_kafka_txn_coord_set (rd_kafka_t *rk, rd_kafka_broker_t *rkb,
|
| H A D | rdkafka_idempotence.c | 441 rd_kafka_txn_coord_set(rk, NULL, "%s", errstr); in rd_buf_write()
|