Searched refs:RD_KAFKA_ERR_ACTION_FATAL (Results 1 – 8 of 8) sorted by relevance
612 p_actions |= RD_KAFKA_ERR_ACTION_FATAL; in rd_kafka_txn_handle_AddPartitionsToTxn()637 (RD_KAFKA_ERR_ACTION_FATAL | in rd_kafka_txn_handle_AddPartitionsToTxn()714 if (actions & RD_KAFKA_ERR_ACTION_FATAL) { in rd_kafka_txn_handle_AddPartitionsToTxn()1450 actions |= RD_KAFKA_ERR_ACTION_FATAL; in rd_kafka_txn_handle_TxnOffsetCommit()1464 if (actions & RD_KAFKA_ERR_ACTION_FATAL) { in rd_kafka_txn_handle_TxnOffsetCommit()1653 actions |= RD_KAFKA_ERR_ACTION_FATAL; in rd_kafka_txn_handle_AddOffsetsToTxn()1678 if (actions & RD_KAFKA_ERR_ACTION_FATAL) { in rd_kafka_txn_handle_AddOffsetsToTxn()1951 actions |= RD_KAFKA_ERR_ACTION_FATAL; in rd_kafka_txn_handle_EndTxn()1960 if (actions & RD_KAFKA_ERR_ACTION_FATAL) { in rd_kafka_txn_handle_EndTxn()
44 #define RD_KAFKA_ERR_ACTION_FATAL 0x200 /**< Fatal error */ macro
454 if (actions & RD_KAFKA_ERR_ACTION_FATAL) in rd_kafka_txn_curr_api_reply()694 p_actions |= RD_KAFKA_ERR_ACTION_FATAL; in rd_kafka_txn_handle_AddPartitionsToTxn()732 (RD_KAFKA_ERR_ACTION_FATAL | in rd_kafka_txn_handle_AddPartitionsToTxn()837 if (actions & RD_KAFKA_ERR_ACTION_FATAL) { in rd_kafka_txn_handle_AddPartitionsToTxn()1612 actions |= RD_KAFKA_ERR_ACTION_FATAL; in rd_kafka_txn_handle_TxnOffsetCommit()1634 if (actions & RD_KAFKA_ERR_ACTION_FATAL) { in rd_kafka_txn_handle_TxnOffsetCommit()1863 actions |= RD_KAFKA_ERR_ACTION_FATAL; in rd_kafka_txn_handle_AddOffsetsToTxn()1895 if (actions & RD_KAFKA_ERR_ACTION_FATAL) { in rd_kafka_txn_handle_AddOffsetsToTxn()2192 RD_KAFKA_ERR_ACTION_FATAL, in rd_kafka_txn_handle_EndTxn()2281 actions |= RD_KAFKA_ERR_ACTION_FATAL; in rd_kafka_txn_handle_EndTxn()[all …]
182 if (actions & (RD_KAFKA_ERR_ACTION_FATAL|RD_KAFKA_ERR_ACTION_PERMANENT)) in rd_kafka_err_action()1105 RD_KAFKA_ERR_ACTION_PERMANENT|RD_KAFKA_ERR_ACTION_FATAL, in rd_kafka_handle_OffsetCommit_error()1218 if (actions & RD_KAFKA_ERR_ACTION_FATAL) { in rd_kafka_handle_OffsetCommit()
454 if (actions & RD_KAFKA_ERR_ACTION_FATAL)694 p_actions |= RD_KAFKA_ERR_ACTION_FATAL;732 (RD_KAFKA_ERR_ACTION_FATAL |837 if (actions & RD_KAFKA_ERR_ACTION_FATAL) {1612 actions |= RD_KAFKA_ERR_ACTION_FATAL;1634 if (actions & RD_KAFKA_ERR_ACTION_FATAL) {1863 actions |= RD_KAFKA_ERR_ACTION_FATAL;1894 if (actions & RD_KAFKA_ERR_ACTION_FATAL) {2185 RD_KAFKA_ERR_ACTION_FATAL,2274 actions |= RD_KAFKA_ERR_ACTION_FATAL;[all …]
1025 RD_KAFKA_ERR_ACTION_PERMANENT|RD_KAFKA_ERR_ACTION_FATAL, in rd_kafka_handle_OffsetCommit_error()1143 if (actions & RD_KAFKA_ERR_ACTION_FATAL) { in rd_kafka_handle_OffsetCommit()