当生成给kafka的消息时，可能会出现两种错误：可重试和不可重试。在处理它们时，您应该如何区分它们？
我想异步生成记录，将其中的记录保存在另一个主题（或hbase）中 callback object 接收一个不可重试的异常，并让生产者为我处理所有接收到可重试异常的异常（最多尝试次数，当它最终到达时，将成为第一个尝试）。
我的问题是：生产商是否仍然会自己处理可检索的异常，尽管 callback object ? 因为在接口回调中说：
可重试异常（暂时的，可以通过增加#重试次数来覆盖）
代码可能是这样的吗？

producer.send(record, callback)

def callback: Callback = new Callback {
    override def onCompletion(recordMetadata: RecordMetadata, e: Exception): Unit = {
      if(null != e) {
         if (e == RecordTooLargeException || e == UnknownServerException || ..) {
            log.error("Winter is comming")
            writeDiscardRecordsToSomewhereElse
         } else {
            log.warn("It's no that cold") //it's retriable. The producer will keep trying by itself?
         }
      } else {
        log.debug("It's summer. Everything is fine")
      }
    }
}

Kafka版本：0.10.0
任何光线都会很好！：）