chore: fix gosec and misspell warnings

IBM · Jan 12, 2022 · 1f754e2 · 1f754e2
1 parent 2441dcb
commit 1f754e2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/consumer.go b/consumer.go
@@ -864,7 +864,7 @@ func (bc *brokerConsumer) handleResponses() {
 				if bc.broker.ID() != preferredBroker.ID() {
 					// not an error but needs redispatching to consume from preferred replica
 					Logger.Printf(
-						"consumer/broker/%d abandoned in favour of preferred replica broker/%d\n",
+						"consumer/broker/%d abandoned in favor of preferred replica broker/%d\n",
 						bc.broker.ID(), preferredBroker.ID())
 					child.trigger <- none{}
 					delete(bc.subscriptions, child)

diff --git a/functional_test.go b/functional_test.go
@@ -264,7 +264,8 @@ func tearDownDockerTestEnvironment(ctx context.Context, env *testEnvironment) er
 }
 
 func startDockerTestBroker(ctx context.Context, brokerID int32) error {
-	c := exec.Command("docker-compose", "start", fmt.Sprintf("kafka-%d", brokerID))
+	service := fmt.Sprintf("kafka-%d", brokerID)
+	c := exec.Command("docker-compose", "start", service)
 	c.Stdout = os.Stdout
 	c.Stderr = os.Stderr
 	if err := c.Run(); err != nil {
@@ -274,7 +275,8 @@ func startDockerTestBroker(ctx context.Context, brokerID int32) error {
 }
 
 func stopDockerTestBroker(ctx context.Context, brokerID int32) error {
-	c := exec.Command("docker-compose", "stop", fmt.Sprintf("kafka-%d", brokerID))
+	service := fmt.Sprintf("kafka-%d", brokerID)
+	c := exec.Command("docker-compose", "stop", service)
 	c.Stdout = os.Stdout
 	c.Stderr = os.Stderr
 	if err := c.Run(); err != nil {