Skip to content

Commit 746d18d

Browse files
committed
Fix #82
1 parent 99bfb07 commit 746d18d

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/converter/FitbitSleepAvroConverter.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -127,6 +127,10 @@ protected Stream<TopicData> processRecords(
127127
})
128128
.collect(Collectors.toList());
129129

130+
if (allRecords.isEmpty()) {
131+
return Stream.empty();
132+
}
133+
130134
// The final group gets the actual offset, to ensure that the group does not get queried
131135
// again.
132136
allRecords.get(allRecords.size() - 1).sourceOffset = startTime;

0 commit comments

Comments
 (0)