K - the key type.V - the value type.public class DefaultAfterRollbackProcessor<K,V> extends java.lang.Object implements AfterRollbackProcessor<K,V>
AfterRollbackProcessor. Seeks all
topic/partitions so the records will be re-fetched, including the failed
record.| Constructor and Description |
|---|
DefaultAfterRollbackProcessor() |
| Modifier and Type | Method and Description |
|---|---|
void |
process(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records,
org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
Process the remaining records.
|
public void process(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
AfterRollbackProcessorprocess in interface AfterRollbackProcessor<K,V>records - the records.consumer - the consumer.