Kafka生产者回调专有

Question

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

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

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

Answer 1

您可能会得到BufferExhaustedException或TimeoutException

Answer 2

根据Callback Java Docs，在回调期间可能发生以下异常：