fix test

petedannemann · petedannemann · commit dc189f24a529 · 2025-05-01T11:50:41.000-04:00
diff --git a/addoffsetstotxn_test.go b/addoffsetstotxn_test.go
@@ -2,6 +2,7 @@ package kafka
 
 import (
 	"context"
+	"errors"
 	"log"
 	"net"
 	"os"
@@ -95,7 +96,7 @@ func TestClientAddOffsetsToTxn(t *testing.T) {
 		}
 
 		// we should retry if the group is still loading
-		if ipResp.Error != GroupLoadInProgress {
+		if ipResp.Error != nil && !errors.Is(ipResp.Error, GroupLoadInProgress) {
 			t.Fatal(ipResp.Error)
 		}
 

Original file line number	Diff line number	Diff line change
`@@ -2,6 +2,7 @@ package kafka`
`2`	`2`
`3`	`3`	`import (`
`4`	`4`	`"context"`
	`5`	`+ "errors"`
`5`	`6`	`"log"`
`6`	`7`	`"net"`
`7`	`8`	`"os"`
`@@ -95,7 +96,7 @@ func TestClientAddOffsetsToTxn(t *testing.T) {`
`95`	`96`	`}`
`96`	`97`
`97`	`98`	`// we should retry if the group is still loading`
`98`		`- if ipResp.Error != GroupLoadInProgress {`
	`99`	`+ if ipResp.Error != nil && !errors.Is(ipResp.Error, GroupLoadInProgress) {`
`99`	`100`	`t.Fatal(ipResp.Error)`
`100`	`101`	`}`
`101`	`102`