Page History

package org.apache.kafka.common.errors;

/**
 * {@code ClientExceptionHandler} that continuesdecides on continuing the transaction evenor ifaborting ait recordbased is too large.
 * Otherwise, it makes on the transactionexception to failtype.
 */
public class TransactionExceptionHandler implements ClientExceptionHandler {

    @Override
    public ClientExceptionHandlerResponse handle(final Exception exception);
}