kudu-client api 1.3.0 怎么配置重试次数

kudu-client API 1.3.0 默认没有提供重试次数配置选项，但可以通过设置 RetryPolicy 来实现重试。

以下是一个使用 RetryPolicy 实现重试的示例：

import org.apache.kudu.client.*;

public class KuduClientRetryExample {

    private static final int MAX_RETRIES = 3;
    private static final long RETRY_SLEEP_MS = 1000;

    public static void main(String[] args) {
        KuduClient client = new KuduClient.KuduClientBuilder("kudu-master:7051").build();

        // 设置重试策略
        RetryPolicy retryPolicy = new RetryPolicy.RetryForever(RetryPolicy.BACKOFF_RANDOM, RETRY_SLEEP_MS);
        KuduSession session = client.newSession();
        session.setMutationBufferSpace(4096);
        session.setFlushMode(SessionConfiguration.FlushMode.MANUAL_FLUSH);

        // 使用重试策略提交操作
        try {
            session.apply(retryPolicy);
            // TODO: 在这里执行 Kudu 操作
        } catch (KuduException e) {
            e.printStackTrace();
        } finally {
            try {
                session.close();
            } catch (KuduException e) {
                e.printStackTrace();
            }
            client.close();
        }
    }

}

这个示例中，我们使用了 RetryForever 策略，该策略会无限重试，直到操作成功或遇到异常。我们还设置了 RETRY_SLEEP_MS 毫秒的随机等待时间，以防止并发请求同时重试导致流量峰值。

如果你想限制重试次数，可以使用 RetryNTimes 策略，如下所示：

RetryPolicy retryPolicy = new RetryPolicy.RetryNTimes(MAX_RETRIES, RETRY_SLEEP_MS);

这个策略会重试最多 MAX_RETRIES 次，如果重试 MAX_RETRIES 次后仍然失败，就会抛出异常。