Page History

package org.apache.kafka.clients.producer;

import org.apache.kafka.clientscommon.producer.ProducerRecordConfigurable;
import org.apache.kafka.common.errors.ConfigurableRecordTooLargeException;
import org.apache.kafka.common.annotation.InterfaceStability.errors.UnknownTopicOrPartitionException;

import java.io.Closeable;

/**
 * Interface that specifies how an the RecordTooLargeException and/or UnknownTopicOrPartitionException should be handled.
 * The accepted responses for RecordTooLargeException are FAIL and SWALLOW. Therefore, RETRY will be interpreted and executed as FAIL.
 */

public interface ProducerExceptionHandler extends Configurable, Closeable {

    /**
     * Determine whether to stop processing, keep retrying internally, or swallow the error by dropping the record.
     *
    For RecordTooLargeException* RETRY@param willrecord beThe interpretedrecord andthat executedfailed asto FAIL.
     *
produce
     * @param exception The exception that occurred during production
     */
    RecordTooLargeExceptionResponse handle(final ProducerRecord record, final RecordTooLargeException exception);

    /**
     * Determine whether to stop processing, keep retrying internally, or swallow the error by dropping the record.
     *
     * @param record The record that failed to produce
     * @param exception The exception that occurred during production
     */
    UnknownTopicOrPartitionExceptionResponse handle(final ProducerRecord record, final UnknownTopicOrPartitionException exception);


    enum RecordTooLargeExceptionResponse {
        /* stop processing: fail */
        FAIL(0, "FAIL"),
        /* drop the record and continue */
        SWALLOW(2, "SWALLOW");

        /**
         * an english description of the api--this is for debugging and can change
         */
        public final String name;

        /**
         * the permanent and immutable id of an API--this can't change ever
         */
        public final int id;

        RecordTooLargeExceptionResponse(final int id, final String name) {
      * @param record The record that failedthis.id to= produceid;
      * @param exception The exception that occurredthis.name during= productionname;
     */
   }
 Response handle(final ProducerRecord record, final Exception exception);

 }
    enum ResponseUnknownTopicOrPartitionExceptionResponse {
        /* stop processing: fail */
        FAIL(0, "FAIL"),
        /* continue: keep retrying */
        RETRY(1, "RETRY"),
        /* continue: swallow the error */
        SWALLOW(2, "SWALLOW");

        /**
         * an english description of the api--this is for debugging and can change
         */
        public final String name;

        /**
         * the permanent and immutable id of an API--this can't change ever
         */
        public final int id;

        ResponseUnknownTopicOrPartitionExceptionResponse(final int id, final String name) {
            this.id = id;
            this.name = name;
        }
    }
}