Class FailedBatchProcessor

All Implemented Interfaces:
DeliveryAttemptAware
Direct Known Subclasses:
DefaultErrorHandler

public abstract class FailedBatchProcessor extends FailedRecordProcessor
Subclass of FailedRecordProcessor that can process (and recover) a batch. If the listener throws a BatchListenerFailedException, the offsets prior to the failed record are committed and the remaining records have seeks performed. When the retries are exhausted, the failed record is sent to the recoverer instead of being included in the seeks. If other exceptions are thrown processing is delegated to the fallback handler.
Since:
2.8
Author:
Gary Russell, Francois Rosiere, Wang Zhiyang