Merge pull request #2345 from Shopify/dnwe/fix-default

fix(consumer): default ResetInvalidOffsets to true
IBM · Sep 27, 2022 · b6728ba · b6728ba
2 parents 338bf4f + d2ee3e1
commit b6728ba
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/config.go b/config.go
@@ -517,7 +517,7 @@ func NewConfig() *Config {
 	c.Consumer.Group.Rebalance.Timeout = 60 * time.Second
 	c.Consumer.Group.Rebalance.Retry.Max = 4
 	c.Consumer.Group.Rebalance.Retry.Backoff = 2 * time.Second
-	c.Consumer.Group.ResetInvalidOffsets = false
+	c.Consumer.Group.ResetInvalidOffsets = true
 
 	c.ClientID = defaultClientID
 	c.ChannelBufferSize = 256