fix: return reset offset error for new connection (#33)

zerodha · Nov 4, 2024 · dba537d · dba537d
1 parent b5059eb
commit dba537d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/relay/source_pool.go b/internal/relay/source_pool.go
@@ -609,11 +609,11 @@ waitForTopicLag:
 	sp.log.Info("resetting offsets for consumer group", "id", s.ID, "server", s.Config.BootstrapBrokers, "offsets", of)
 	resp, err := admCl.CommitOffsets(ctx, sp.cfg.GroupID, of)
 	if err != nil {
-		sp.log.Error("error resetting group offset", "err", err)
+		return fmt.Errorf("error resetting group offset: %w", err)
 	}
 
 	if err := resp.Error(); err != nil {
-		sp.log.Error("error resetting group offset", "err", err)
+		return fmt.Errorf("error resetting group offset: %w", err)
 	}
 
 	// _ = resp