Also clear out credentials when tasks are stopped

DIMO-Network · Nov 6, 2024 · b13fa5b · b13fa5b
1 parent 7335acf
commit b13fa5b
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/cmd/devices-api/individual_kafka_task.go → cmd/devices-api/stop_task_key.go b/cmd/devices-api/individual_kafka_task.go → cmd/devices-api/stop_task_key.go
@@ -76,11 +76,18 @@ func stopTaskByKey(settings *config.Settings, taskKey string, producer sarama.Sy
 		return err
 	}
 
-	_, _, err = producer.SendMessage(
-		&sarama.ProducerMessage{
-			Topic: settings.TaskStopTopic,
-			Key:   sarama.StringEncoder(taskKey),
-			Value: sarama.ByteEncoder(ttb),
+	err = producer.SendMessages(
+		[]*sarama.ProducerMessage{
+			{
+				Topic: settings.TaskStopTopic,
+				Key:   sarama.StringEncoder(taskKey),
+				Value: sarama.ByteEncoder(ttb),
+			},
+			{
+				Topic: settings.TaskCredentialTopic,
+				Key:   sarama.StringEncoder(taskKey),
+				Value: nil,
+			},
 		},
 	)