public interface ErrorHandler extends GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>>
MessageListener
handle, handle