java - 运行线程时的异常处理

Question

我有一个具有kafka使用者的应用程序，并根据接收到的数据更新Elastic搜索。

我的问题是，当ES发生故障时，kafka使用者会完全停止并且不会重新启动。

我相信这是由于我的ES代码的运行方式:

public CompletionStage<SearchResponse> executeSearch(SearchRequest searchRequest) {
        CompletableFuture<SearchResponse> f = new CompletableFuture<>();

        client.searchAsync(searchRequest, RequestOptions.DEFAULT, new ActionListener<SearchResponse>() {
            @Override
            public void onResponse(SearchResponse searchResponse) {
                f.complete(searchResponse);
            }

            @Override
            public void onFailure(Exception e) {

                throw new Exception();  // I am guessing because of this
            }
        });
        return f;
} 

如果我将 onFailure方法更改为:

            public void onFailure(Exception e) {

                f.complete(null);
            }

它运行完美，但是我不明白为什么引发异常会导致这种情况。

任何帮助将不胜感激。

Answer 1

对于那些需要解决方案的人，我将代码更改为以下代码，使其可以正常工作:

public void onFailure(Exception e) {
    f.completeExceptionally(new Exception());
}