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

kalbhor · web-flow · commit dba537df3e5d · 2024-11-04T16:54:10.000+05:30
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

Original file line number	Diff line number	Diff line change
`@@ -609,11 +609,11 @@ waitForTopicLag:`
`609`	`609`	`sp.log.Info("resetting offsets for consumer group", "id", s.ID, "server", s.Config.BootstrapBrokers, "offsets", of)`
`610`	`610`	`resp, err := admCl.CommitOffsets(ctx, sp.cfg.GroupID, of)`
`611`	`611`	`if err != nil {`
`612`		`- sp.log.Error("error resetting group offset", "err", err)`
	`612`	`+ return fmt.Errorf("error resetting group offset: %w", err)`
`613`	`613`	`}`
`614`	`614`
`615`	`615`	`if err := resp.Error(); err != nil {`
`616`		`- sp.log.Error("error resetting group offset", "err", err)`
	`616`	`+ return fmt.Errorf("error resetting group offset: %w", err)`
`617`	`617`	`}`
`618`	`618`
`619`	`619`	`// _ = resp`