java - 等待 kafkaTemplate 待处理的 future

Question

我正在执行一个异步操作，该操作在循环中返回一个 future 对象(比如 10 条消息)。据我了解，当 Future 完成其任务时，回调方法会自动触发并执行。

假设我的第七个 future 正处于等待阶段。我怎样才能异常(exception)地完成这个 future ？

处理这种情况的最佳方法是什么。

List<ListenableFuture<SendResult<String, String>>> cf = new ArrayList<ListenableFuture<SendResult<String, String>>>();

future = kafkaTemplate.send(topicName, message);
cf.add(future);

i++;

future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {

    @Override
    public void onSuccess(SendResult<String, String> result) {
        syso("sent success");
    }

    @Override
    public void onFailure(Throwable ex) {
        System.out.println(" sending failed");
    }
});

Answer 1

你为什么要这么做？

如果出现异常，kafka-clients将调用模板的回调并抛出异常，模板将异常完成future。

如果您出于某种原因确实需要这样做(但我想了解原因)，您可以将其转换为 SettableListenerFuture。