Add tests for new scaleToZeroOnInvalidOffset configuration

Signed-off-by: Ram Cohen <[email protected]>
kedacore · Mar 30, 2022 · b1042f0 · b1042f0
1 parent 41b5d81
commit b1042f0
Show file tree

Hide file tree

Showing 2 changed files with 122 additions and 143 deletions.
diff --git a/pkg/scalers/kafka_scaler.go b/pkg/scalers/kafka_scaler.go
@@ -360,7 +360,7 @@ func (s *kafkaScaler) getLagForPartition(topic string, partitionID int32, offset
 			retVal = 0
 		}
 		errMsg := fmt.Errorf(
-			"invalid offset found for topic %s in group %s and partition %d, probably no offset is committed yet. Scaling to %d",
+			"invalid offset found for topic %s in group %s and partition %d, probably no offset is committed yet. Returning with lag of %d",
 			topic, s.metadata.group, partitionID, retVal)
 		kafkaLog.V(0).Info(errMsg.Error())
 		return retVal, errMsg