lib/jets/job/dsl/kinesis_event.rb in jets-4.0.12 vs lib/jets/job/dsl/kinesis_event.rb in jets-5.0.0.beta1

@@ -9,12 +9,12 @@
       iam_policy_props = options.delete(:iam_policy) || @iam_policy || default_iam_policy
       iam_policy(iam_policy_props) unless iam_policy_props == :disable
 
       props = options # by this time options only has EventSourceMapping properties
       default = {
-        event_source_arn: stream_arn,
-        starting_position: "LATEST",
+        EventSourceArn: stream_arn,
+        StartingPosition: "LATEST",
       }
       props = default.merge(props)
 
       event_source_mapping(props)
     end
@@ -32,15 +32,15 @@
       "arn:aws:kinesis:#{Jets.aws.region}:#{Jets.aws.account}:stream/#{stream_name}"
     end
 
     def default_kinesis_stream_policy(stream_name_arn='*')
       {
-        action: ["kinesis:GetRecords",
+        Action: ["kinesis:GetRecords",
                  "kinesis:GetShardIterator",
                  "kinesis:DescribeStream",
                  "kinesis:ListStreams"],
-        effect: "Allow",
-        resource: stream_name_arn,
+        Effect: "Allow",
+        Resource: stream_name_arn,
       }
     end
   end
 end
\ No newline at end of file