style: make linter happy

Signed-off-by: Samantha Coyle <[email protected]>

common/authentication/aws/x509.go

@@ -463,7 +463,7 @@ func (a *x509) refreshClient() {
 	for {
 		newSession, err := a.createOrRefreshSession(context.Background())
 		if err == nil {
-			err := a.clients.refresh(newSession)
+			err = a.clients.refresh(newSession)
 			if err != nil {
 				a.logger.Errorf("Failed to refresh client, retrying in 5 seconds: %w", err)
 			}

common/component/kafka/clients.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 
 	"github.com/IBM/sarama"
+
 	awsAuth "github.com/dapr/components-contrib/common/authentication/aws"
 )
 

common/component/kafka/kafka.go

@@ -124,7 +124,6 @@ func NewKafka(logger logger.Logger) *Kafka {
 	}
 }
 
-
 // Init does metadata parsing and connection establishment.
 func (k *Kafka) Init(ctx context.Context, metadata map[string]string) error {
 	upgradedMetadata, err := k.upgradeMetadata(metadata)

common/component/kafka/kafka_test.go

@@ -421,7 +421,7 @@ func TestValidateAWS(t *testing.T) {
 			} else {
 				require.NoError(t, err)
 			}
-			assert.Equal(t, result, tt.expected)
+			assert.Equal(t, tt.expected, result)
 		})
 	}
 }

common/component/kafka/producer.go

@@ -93,7 +93,7 @@ func (k *Kafka) Publish(_ context.Context, topic string, data []byte, metadata m
 func (k *Kafka) BulkPublish(_ context.Context, topic string, entries []pubsub.BulkMessageEntry, metadata map[string]string) (pubsub.BulkPublishResponse, error) {
 	clients, err := k.latestClients()
 	if err != nil || clients == nil {
-		err := fmt.Errorf("failed to get latest Kafka clients: %w", err)
+		err = fmt.Errorf("failed to get latest Kafka clients: %w", err)
 		return pubsub.NewBulkPublishResponse(entries, err), err
 	}
 	if clients.producer == nil {