return if kafka offset response is nil (#689)

Signed-off-by: Timo Zingel <[email protected]>
kedacore · Mar 17, 2020 · 3692eca · 3692eca
1 parent 75878a9
commit 3692eca
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/scalers/kafka_scaler.go b/pkg/scalers/kafka_scaler.go
@@ -288,6 +288,10 @@ func (s *kafkaScaler) getOffsets(partitions []int32) (*sarama.OffsetFetchRespons
 
 func (s *kafkaScaler) getLagForPartition(partition int32, offsets *sarama.OffsetFetchResponse) int64 {
 	block := offsets.GetBlock(s.metadata.topic, partition)
+	if block == nil {
+		kafkaLog.Error(fmt.Errorf("error finding offset block for topic %s and partition %d", s.metadata.topic, partition), "")
+		return 0
+	}
 	consumerOffset := block.Offset
 	latestOffset, err := s.client.GetOffset(s.metadata.topic, partition, sarama.OffsetNewest)
 	if err != nil {