Package com.broadleafcommerce.common.messaging.autoconfigure.kafka

Class KafkaLoggingConsumerRecordRecoverer

java.lang.Object

com.broadleafcommerce.common.messaging.autoconfigure.kafka.KafkaLoggingConsumerRecordRecoverer

All Implemented Interfaces:

BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,Exception>, org.springframework.kafka.listener.ConsumerRecordRecoverer

public class KafkaLoggingConsumerRecordRecoverer
extends Object
implements org.springframework.kafka.listener.ConsumerRecordRecoverer

Simple logging recoverer

Constructor Summary

Constructors

Constructor	Description
KafkaLoggingConsumerRecordRecoverer()

Method Summary

Modifier and Type	Method	Description
void	accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord, Exception e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.BiConsumer

andThen

Constructor Details

KafkaLoggingConsumerRecordRecoverer

public KafkaLoggingConsumerRecordRecoverer()

Method Details

accept

public void accept(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> consumerRecord,
 Exception e)

Specified by:

accept in interface BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,Exception>