Fix golint errors in CI

Signed-off-by: Hao Sun <[email protected]>
IBM · Sep 8, 2023 · 19b1221 · 19b1221
1 parent ede5508
commit 19b1221
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/async_producer_test.go b/async_producer_test.go
@@ -733,6 +733,7 @@ func TestAsyncProducerMultipleRetriesWithConcurrentRequests(t *testing.T) {
 }
 
 func TestAsyncProducerBrokerRestart(t *testing.T) {
+	// Logger = log.New(os.Stdout, "[sarama] ", log.LstdFlags)
 
 	seedBroker := NewMockBroker(t, 1)
 	leader := NewMockBroker(t, 2)

diff --git a/functional_test.go b/functional_test.go
@@ -228,7 +228,7 @@ mainLoop:
 			}
 			for _, broker := range brokers {
 				err := broker.Open(client.Config())
-				if err != nil && err != ErrAlreadyConnected {
+				if err != nil && !errors.Is(err, ErrAlreadyConnected) {
 					client.Close()
 					continue retryLoop
 				}