public class ConsumerChainedExceptionHandler extends Object implements BiConsumer<org.apache.kafka.clients.consumer.Consumer<?,?>,RuntimeException>
Constructor and Description |
---|
ConsumerChainedExceptionHandler() |
ConsumerChainedExceptionHandler(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 ConsumerChainedExceptionHandler()
public ConsumerChainedExceptionHandler(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>
Copyright © 2020 Red Hat. All rights reserved.