Skip to content

Commit 6591743

Browse files
minor rename of variable
1 parent d3b914a commit 6591743

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ protected Stream<TopicData> processRecords(
5151
Instant time =
5252
startDate.with(LocalTime.parse(activity.get("time").asText())).toInstant();
5353

54-
FitbitIntradayCalories steps =
54+
FitbitIntradayCalories calories =
5555
new FitbitIntradayCalories(
5656
time.toEpochMilli() / 1000d,
5757
timeReceived,
@@ -60,7 +60,7 @@ protected Stream<TopicData> processRecords(
6060
activity.get("level").asInt(),
6161
activity.get("mets").asDouble());
6262

63-
return new TopicData(time, caloriesTopic, steps);
63+
return new TopicData(time, caloriesTopic, calories);
6464
},
6565
(a, ex) ->
6666
logger.warn(

0 commit comments

Comments
 (0)