关于bulkprocessor。小弟有几个疑问请教各位大神:
1、setConcurrentRequests设置是不是相当于开起多线程发送request请求、比如我设置了2,是不是指相当于三条线程在处理发送request请求。
2、setBackoffPolicy设置了重试机制。我想在重试三次后有异常退出程序。但是现在不知道如何拿到这个已经重试次数。
1、setConcurrentRequests设置是不是相当于开起多线程发送request请求、比如我设置了2,是不是指相当于三条线程在处理发送request请求。
2、setBackoffPolicy设置了重试机制。我想在重试三次后有异常退出程序。但是现在不知道如何拿到这个已经重试次数。
1 个回复
Cheetah
赞同来自:
2. setBackoffPolicy( BackoffPolicy.exponentialBackoff(TimeValue.timeValueMillis(100), 3)),这种设置的是最大3次重试,异常,重试等都是在回调函数里做的