We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent afc3e3f commit 51a6c4bCopy full SHA for 51a6c4b
kafka-connect-oura-source/src/main/java/org/radarbase/connect/rest/oura/OuraSourceTask.java
@@ -126,9 +126,8 @@ public Stream<RestRequest> requests() {
126
}
127
128
private List<Route> getRotatedRoutes() {
129
- int routeStart = routeStartIndex % this.routes.size();
130
List<Route> rotatedRoutes = new ArrayList<>(this.routes);
131
- Collections.rotate(rotatedRoutes, routeStart);
+ Collections.rotate(rotatedRoutes, routeStartIndex % this.routes.size());
132
routeStartIndex = (routeStartIndex + 1) % this.routes.size();
133
return rotatedRoutes;
134
0 commit comments