Kafka生产者回调异常

Question

当我们产生消息时，我们可以定义一个回调，该回调可能会发生异常：

kafkaProducer.send(producerRecord, new Callback() {
  public void onCompletion(RecordMetadata recordMetadata, Exception e) {
    if (e == null) {
      // OK
    } else {
      // NOT OK
    }
  }
});

考虑到生产者中的内置重试逻辑，我想知道开发者应明确处理哪种异常？

Answer 1

在处理此记录期间引发的异常。如果未发生错误，则为Null。可能引发的异常包括：

Answer 2