Use right timestamp for low/high water mark request

redpanda-data · Feb 24, 2021 · 8db3809 · 8db3809
1 parent a9e4731
commit 8db3809
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/prometheus/collect_topic_partition_offsets.go b/prometheus/collect_topic_partition_offsets.go
@@ -13,13 +13,13 @@ func (e *Exporter) collectTopicPartitionOffsets(ctx context.Context, ch chan<- p
 	isOk := true
 
 	// Low Watermarks
-	lowWaterMarks, err := e.minionSvc.ListOffsetsCached(ctx, -1)
+	lowWaterMarks, err := e.minionSvc.ListOffsetsCached(ctx, -2)
 	if err != nil {
 		e.logger.Error("failed to fetch low water marks", zap.Error(err))
 		return false
 	}
 	// High Watermarks
-	highWaterMarks, err := e.minionSvc.ListOffsetsCached(ctx, -2)
+	highWaterMarks, err := e.minionSvc.ListOffsetsCached(ctx, -1)
 	if err != nil {
 		e.logger.Error("failed to fetch low water marks", zap.Error(err))
 		return false