fix: checks on kafka startingpositiontimestamp param

serverless · Nov 4, 2022 · 3b8b94a · 3b8b94a
1 parent fe3b9e6
commit 3b8b94a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/plugins/aws/package/compile/events/kafka.js b/lib/plugins/aws/package/compile/events/kafka.js
@@ -154,7 +154,7 @@ class AwsCompileKafkaEvents {
         const startingPosition = event.kafka.startingPosition || 'TRIM_HORIZON';
         const startingPositionTimestamp = event.kafka.startingPositionTimestamp;
 
-        if (startingPosition === 'AT_TIMESTAMP' && !startingPositionTimestamp) {
+        if (startingPosition === 'AT_TIMESTAMP' && startingPositionTimestamp != null) {
           throw new ServerlessError(
             `You must specify startingPositionTimestamp for function: ${functionName} when startingPosition is AT_TIMESTAMP.`,
             'FUNCTION_KAFKA_STARTING_POSITION_TIMESTAMP_INVALID'
@@ -254,7 +254,7 @@ class AwsCompileKafkaEvents {
           };
         }
 
-        if (startingPositionTimestamp !== undefined) {
+        if (startingPositionTimestamp != null) {
           kafkaResource.Properties.StartingPositionTimestamp = startingPositionTimestamp;
         }