Interface ConsumerAwareRecordRecoverer
- All Superinterfaces:
BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,,?>, Exception> ConsumerRecordRecoverer
- All Known Implementing Classes:
DeadLetterPublishingRecoverer
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
A
ConsumerRecordRecoverer that supports getting a reference to the
Consumer.- Since:
- 2.7
- Author:
- Gary Russell
-
Method Summary
Methods inherited from interface java.util.function.BiConsumer
andThen
-
Method Details
-
accept
default void accept(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, Exception exception) - Specified by:
acceptin interfaceBiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>, Exception>
-
accept
void accept(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> record, @Nullable org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, Exception exception) Recover the record.- Parameters:
record- the record.consumer- the consumer.exception- the exception.- Since:
- 2.7
-