Interface ConsumerAwareRecordRecoverer
-
- All Superinterfaces:
java.util.function.BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,java.lang.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.
@FunctionalInterface public interface ConsumerAwareRecordRecoverer extends ConsumerRecordRecoverer
AConsumerRecordRecovererthat supports getting a reference to theConsumer.- Since:
- 2.7
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default voidaccept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, java.lang.Exception exception)voidaccept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.lang.Exception exception)Recover the record.
-
-
-
Method Detail
-
accept
default void accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, java.lang.Exception exception)- Specified by:
acceptin interfacejava.util.function.BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,java.lang.Exception>
-
accept
void accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.lang.Exception exception)Recover the record.- Parameters:
record- the record.consumer- the consumer.exception- the exception.- Since:
- 2.7
-
-