fix: Fix kinesis_target and kinesis_parameters dynamic blocks (#124)

Author: mschuwalow

examples/complete/main.tf

@@ -105,11 +105,12 @@ module "eventbridge" {
         attach_role_arn = true
       },
       {
-        name              = "send-orders-to-kinesis"
-        arn               = aws_kinesis_stream.this.arn
-        dead_letter_arn   = aws_sqs_queue.dlq.arn
-        input_transformer = local.order_input_transformer
-        attach_role_arn   = true
+        name               = "send-orders-to-kinesis"
+        arn                = aws_kinesis_stream.this.arn
+        dead_letter_arn    = aws_sqs_queue.dlq.arn
+        input_transformer  = local.order_input_transformer
+        partition_key_path = "$.id"
+        attach_role_arn    = true
       },
       {
         name            = "process-email-with-ecs-task",

examples/with-schedules/README.md

@@ -28,6 +28,7 @@ Note that this example may create resources which cost money. Run `terraform des
 
 | Name | Version |
 |------|---------|
+| <a name="provider_aws"></a> [aws](#provider\_aws) | >= 5.27 |
 | <a name="provider_null"></a> [null](#provider\_null) | >= 2.0 |
 | <a name="provider_random"></a> [random](#provider\_random) | >= 3.0 |
 
@@ -42,6 +43,7 @@ Note that this example may create resources which cost money. Run `terraform des
 
 | Name | Type |
 |------|------|
+| [aws_kinesis_stream.this](https://registry.terraform.io/providers/hashicorp/aws/latest/docs/resources/kinesis_stream) | resource |
 | [null_resource.download_package](https://registry.terraform.io/providers/hashicorp/null/latest/docs/resources/resource) | resource |
 | [random_pet.this](https://registry.terraform.io/providers/hashicorp/random/latest/docs/resources/pet) | resource |
 

examples/with-schedules/main.tf

@@ -42,6 +42,12 @@ module "eventbridge" {
       schedule_expression = "rate(10 hours)"
       arn                 = module.lambda.lambda_function_arn
     }
+    kinesis-cron = {
+      group_name          = "prod"
+      schedule_expression = "rate(10 hours)"
+      arn                 = aws_kinesis_stream.this.arn
+      partition_key       = "foo"
+    }
   }
 }
 
@@ -53,6 +59,11 @@ resource "random_pet" "this" {
   length = 2
 }
 
+resource "aws_kinesis_stream" "this" {
+  name        = random_pet.this.id
+  shard_count = 1
+}
+
 #############################################
 # Using packaged function from Lambda module
 #############################################

main.tf

@@ -195,10 +195,10 @@ resource "aws_cloudwatch_event_target" "this" {
   }
 
   dynamic "kinesis_target" {
-    for_each = lookup(each.value, "kinesis_target", null) != null ? [true] : []
+    for_each = lookup(each.value, "partition_key_path", null) != null ? [true] : []
 
     content {
-      partition_key_path = lookup(kinesis_target.value, "partition_key_path", null)
+      partition_key_path = each.value.partition_key_path
     }
   }
 
@@ -561,10 +561,10 @@ resource "aws_scheduler_schedule" "this" {
     }
 
     dynamic "kinesis_parameters" {
-      for_each = lookup(each.value, "kinesis_parameters", null) != null ? [true] : []
+      for_each = lookup(each.value, "partition_key", null) != null ? [true] : []
 
       content {
-        partition_key = kinesis_parameters.value.partition_key
+        partition_key = each.value.partition_key
       }
     }