当我们产生消息时,我们可以定义一个回调,该回调可能会发生异常:
kafkaProducer.send(producerRecord, new Callback() {
public void onCompletion(RecordMetadata recordMetadata, Exception e) {
if (e == null) {
// OK
} else {
// NOT OK
}
}
});
考虑到生产者中的内置重试逻辑,我想知道开发者应明确处理哪种异常?