Kafka中FutureRecordMetadata future 怎么获取回调函数

在Kafka中，可以通过调用Future对象的get()方法来获取回调函数。该方法会阻塞当前线程，直到Future对象完成或者发生异常。

示例代码如下：

Future<RecordMetadata> future = producer.send(record);
try {
    RecordMetadata metadata = future.get();
    // 回调函数处理逻辑
} catch (InterruptedException e) {
    e.printStackTrace();
} catch (ExecutionException e) {
    e.printStackTrace();
}

在上述代码中，我们通过producer.send()方法发送消息，并得到一个Future对象。接着，通过调用future.get()方法获取回调函数的返回结果，即RecordMetadata对象。如果在获取结果时发生InterruptedException或者ExecutionException异常，可以通过捕获异常进行处理。