public interface ErrorHandler extends GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
MessageListener
.Modifier and Type | Method and Description |
---|---|
void |
handle(java.lang.Exception thrownException,
org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data) |
void handle(java.lang.Exception thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> data)
handle
in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>