我们有一个使用cassandra作为数据存储的应用程序。为了方便访问，相同的数据需要存储在具有不同分区键的多个表中。为了将数据存储到多个表中，使用了批处理语句。使用batch语句的原因是为了确保数据写入all或none。
通过这种设置，最近我们开始看到由于用户基数的增加而导致的许多写入超时错误。我们看到许多博客和文章提到batchstatements被错误地用于存储多个分区。
参考文献：
https://docs.datastax.com/en/dse/6.0/cql/cql/cql_using/usebatchgoodexample.html
Cassandra的批量限制是多少？
cassandra批处理语句多表
https://grokbase.com/t/cassandra/user/153gsmdzs6/writing-to-multiple-tables
其原因似乎是协调器节点上的负载过大，进而导致延迟。在cassandra.yaml中有一个选项可以将write\ u request\ u timeout\ in\ ms增加到比默认值5 s更高的值。我们尝试了此操作，但请求仍然失败。因此，我们将此设置更新为现在使用executeasync。这样，writetimeout异常就完全消失了。
但现在的问题是-我们如何处理原子性？下面是更新后使用executeasync的代码。使用executeasync是否是使用批处理语句的正确替代方法？是否有任何方法可以在异常块中处理回滚？

try {
    for (ListenableFuture<ResultSet> futureItem : futureItems) {
        futureItem.get();
    }
} catch (Exception e) {
    // need to handle rollback ?
}