ResourceOptions options = prepareOptions(TokenProvider.NAKADI_CONFIG_WRITE);
return client.resourceProvider().newResource()
.requestThrowing(Resource.DELETE, url, options);</BUG>
}
@Override
public CursorCommitResultCollection checkpoint(Map<String, String> context, Cursor... cursors)
throws AuthorizationException, ClientException, ServerException, InvalidException,
<BUG>RateLimitException, ContractException, NakadiException {
PolicyBackoff backoff = ExponentialBackoff.newBuilder()
.initialInterval(900, TimeUnit.MILLISECONDS)
.maxAttempts(3)
.maxInterval(2000, TimeUnit.MILLISECONDS)
.build();</BUG>
return checkpoint(backoff, context, cursors);

.maxInterval(6000, TimeUnit.MILLISECONDS)
.build();
}
private PolicyBackoff policyBackoffForFind() {
return ExponentialBackoff.newBuilder()
.initialInterval(600, TimeUnit.MILLISECONDS)
