address comment

Signed-off-by: Jinli Liang <paul.liang@rokt.com>
kedacore · Dec 22, 2021 · 36a3ae4 · 36a3ae4
1 parent 5f659f9
commit 36a3ae4
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/scalers/kafka_scaler.go b/pkg/scalers/kafka_scaler.go
@@ -313,6 +313,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