Skip to content

Commit f3d9cc0

Browse files
committed
Fix user repository request
1 parent 4b8458f commit f3d9cc0

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/user/ServiceUserRepository.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,7 @@ public boolean hasPendingUpdates() {
150150
@Override
151151
public void applyPendingUpdates() throws IOException {
152152
logger.info("Requesting user information from webservice");
153-
Request request = requestFor("users?source-type=FitBit&page=1&size=" + Integer.MAX_VALUE).build();
153+
Request request = requestFor("users?source-type=FitBit").build();
154154
this.timedCachedUsers =
155155
this.<Users>makeRequest(request, USER_LIST_READER).getUsers().stream()
156156
.filter(u -> u.isComplete()

0 commit comments

Comments
 (0)