public interface ErrorHandler
MessageListener
void
handle(java.lang.Exception thrownException, KafkaMessage message)
void handle(java.lang.Exception thrownException, KafkaMessage message)