K - the key type.V - the value type.@FunctionalInterface
public interface AfterRollbackProcessor<K,V>
| 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.
|