Merge pull request #148 from alenkacz/av/no-logger-fatal

do not use logger.Fatal when testing connection
redpanda-data · May 29, 2022 · 2f6ccdf · 2f6ccdf
2 parents 52a26f9 + f848ea9
commit 2f6ccdf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/service.go b/kafka/service.go
@@ -48,7 +48,7 @@ func (s *Service) CreateAndTestClient(ctx context.Context, l *zap.Logger, opts [
 	defer cancel()
 	err = s.testConnection(client, connectCtx)
 	if err != nil {
-		logger.Fatal("failed to test connectivity to Kafka cluster", zap.Error(err))
+		return nil, fmt.Errorf("failed to test connectivity to Kafka cluster %w", err)
 	}
 
 	return client, nil