public class ConsumerSkipRecordsSerializationExceptionHandler extends ConsumerChainedExceptionHandler
Constructor and Description |
---|
ConsumerSkipRecordsSerializationExceptionHandler() |
ConsumerSkipRecordsSerializationExceptionHandler(BiConsumer<org.apache.kafka.clients.consumer.Consumer<?,?>,RuntimeException> nextHandler) |
Modifier and Type | Method and Description |
---|---|
void |
accept(org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
RuntimeException e) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
andThen
public ConsumerSkipRecordsSerializationExceptionHandler()
public ConsumerSkipRecordsSerializationExceptionHandler(BiConsumer<org.apache.kafka.clients.consumer.Consumer<?,?>,RuntimeException> nextHandler)
public void accept(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, RuntimeException e)
accept
in interface BiConsumer<org.apache.kafka.clients.consumer.Consumer<?,?>,RuntimeException>
accept
in class ConsumerChainedExceptionHandler
Copyright © 2020 Red Hat. All rights reserved.