@Override
        public void run() {
            String name = event.toString();
            scheduleInternalOperation("OperationTimeout(name=" + name + ", tp=" + tp + ")", tp,
                () -> event.complete(new TimeoutException(name + " timed out after " + delayMs + "ms")));
        }
Completes a transaction.

@param producerId        The producer id.
@param producerEpoch     The producer epoch.
@param coordinatorEpoch  The coordinator epoch of the transaction coordinator.
@param result            The transaction result.
@param event             The event that must be completed when the
                         control record is written.
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java