address comment

Signed-off-by: Jinli Liang <[email protected]>
kedacore · Jan 11, 2022 · f8b6735 · f8b6735
1 parent 41d7ad2
commit f8b6735
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/scalers/kafka_scaler.go b/pkg/scalers/kafka_scaler.go
@@ -309,6 +309,10 @@ func (s *kafkaScaler) getTopicPartitions() (map[string][]int32, error) {
 		return nil, fmt.Errorf("error describing topics: %s", err)
 	}
 
+	if s.metadata.topic != "" && len(topicsMetadata) != 1 {
+		return nil, fmt.Errorf("expected only 1 topic metadata, got %d", len(topicsMetadata))
+	}
+
 	topicPartitions := make(map[string][]int32, len(topicsMetadata))
 	for _, topicMetadata := range topicsMetadata {
 		partitionMetadata := topicMetadata.Partitions