Add comment.

artie-labs · Aug 16, 2024 · f114966 · f114966
1 parent a05fd15
commit f114966
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/processes/consumer/flush.go b/processes/consumer/flush.go
@@ -129,7 +129,8 @@ func flush(ctx context.Context, dest destination.Baseline, metricsClient base.Cl
 	}
 
 	if err = commitOffset(ctx, _tableData.TopicConfig().Topic, _tableData.PartitionsToLastMessage); err != nil {
-		return fmt.Errorf("failed to commit offset: %w", err)
+		// Failure to commit Kafka offset shouldn't force the whole flush process to retry.
+		slog.Warn("Failed to commit Kafka offset", slog.Any("err", err), slog.String("tableName", _tableName))
 	}
 
 	return nil