diff --git a/kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/converter/FitbitIntradayStepsAvroConverter.java b/kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/converter/FitbitIntradayStepsAvroConverter.java
index 2381afa4..1751acca 100644
--- a/kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/converter/FitbitIntradayStepsAvroConverter.java
+++ b/kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/converter/FitbitIntradayStepsAvroConverter.java
@@ -67,8 +67,8 @@ protected Stream<TopicData> processRecords(
     ZonedDateTime startDate = request.getDateRange().end();
 
     return iterableToStream(dataset)
+        .filter(activity -> activity.get("value") != null && activity.get("value").asInt() != 0)
         .map(tryOrNull(activity -> {
-
           Instant time = startDate
               .with(LocalTime.parse(activity.get("time").asText()))
               .toInstant();