fixed instant speed calculation

proxima-one · Dec 28, 2022 · 8238c93 · 8238c93
1 parent 8e66c2c
commit 8238c93
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/utils/logger.go b/pkg/utils/logger.go
@@ -132,7 +132,7 @@ func streamRowFromData(lastLoggedTime time.Time, streamId string, data *streamDa
 		data.lastProcessedEvent.Timestamp.Time().Format("2006-01-02 15:04:05"),
 		fmt.Sprintf("%.2f", avgSpeed),
 		fmt.Sprintf("%.2f", divideAsFloats(
-			1000.*data.messagesProcessed-data.messagesProcessedWhenLastLogged,
+			1000.*(data.messagesProcessed-data.messagesProcessedWhenLastLogged),
 			lastLoggedTime.Sub(data.startTime).Milliseconds(),
 		)),
 		processedPercent,