fix: handle http status 501 when fetch topics from a powered off clus…

…ter (#26)
idealo · Nov 7, 2022 · c778ad3 · c778ad3
1 parent d988a9c
commit c778ad3
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/internal/pkg/client.go b/internal/pkg/client.go
@@ -25,7 +25,13 @@ func (c AivenClient) GetAccountTeamMembersList(accountId string, teamId string)
 
 func (c AivenClient) GetKafkaTopicsList(projectName string, serviceName string) []*aiven.KafkaListTopic {
 	topics, err := c.client.KafkaTopics.List(projectName, serviceName)
-	handle(err)
+	if aivenError, ok := err.(aiven.Error); ok {
+		if aivenError.Status == 501 {
+			// Aiven returns 501 if a Kafka Cluster is powered off
+			return nil
+		}
+		handle(err)
+	}
 	return topics
 }