是的,PHP rdkafka支持事務處理??梢允褂?code>rdkafka\Producer::beginTransaction()開始一個事務,使用rdkafka\Producer::commitTransaction()提交事務,使用rdkafka\Producer::abortTransaction()取消事務。事務處理能夠確保消息的原子性,并且保證消息要么全部被成功發送,要么全部失敗。
rdkafka\Producer::commitTransaction()
rdkafka\Producer::abortTransaction()