@Override
        public void run() {
            try {
                withActiveContextOrThrow(tp, context -> {
                    context.completeTransaction(
                        producerId,
                        producerEpoch,
                        coordinatorEpoch,
                        result,
                        this
                    );

                    if (!future.isDone()) {
                        operationTimeout = new OperationTimeout(tp, this, writeTimeout.toMillis());
                        timer.add(operationTimeout);
                    }
                });
            } catch (Throwable t) {
                complete(t);
            }
        }
Called by the CoordinatorEventProcessor when the event is executed.
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java