kudu-client api 1.3.0 怎么配置重试次数
时间: 2024-05-03 13:21:24 浏览: 87
kudu-client驱动
Kudu-Client API 1.3.0 可以通过设置 RetryPolicy 来配置重试次数。具体做法如下:
1. 创建 RetryPolicy 对象
```java
RetryPolicy retryPolicy = new RetryPolicy.RetryForever(
new RetryPolicy.BackoffDelay(1000, 5000, TimeUnit.MILLISECONDS));
```
上面的代码创建了一个无限重试的 RetryPolicy 对象,每次重试之间的间隔时间为 1 秒到 5 秒之间随机值。
2. 使用 RetryPolicy 对象创建 KuduClient 对象
```java
KuduClient client = new KuduClient.KuduClientBuilder("master-1:7051,master-2:7051")
.defaultAdminOperationTimeoutMs(60000)
.retryPolicy(retryPolicy)
.build();
```
上面的代码创建了一个 KuduClient 对象,并将上一步创建的 RetryPolicy 对象作为参数传递给 retryPolicy() 方法。
这样,当 KuduClient 连接到 Kudu 集群时,如果出现连接失败的情况,会自动重试,直到连接成功为止。重试次数由 RetryPolicy 控制。
阅读全文