(PECL rdkafka >= 4.1.0, librdkafka >= 1.4.0)
RdKafka\Producer::initTransactions — Initialize transactions
$timeout_ms) : void
Initialize transactions for the producer instance. This function ensures any transactions initiated by previous instances of the producer with the same transactional.id are completed. If the previous instance failed with a transaction in progress the previous transaction will be aborted. This function needs to be called before any other transactional or produce functions are called when the transactional.id is configured.
Specifies the amount of time (in milliseconds) that the call will try to initialize transaction capability.
In case of success returns NULL, in case of error a RdKafka\KafkaErrorException will be thrown.