feat: Add dynamic blocks for consumer group id config (#399)

Co-authored-by: Anton Babenko <anton@antonbabenko.com>
terraform-aws-modules · Mar 10, 2023 · 7d7bb79 · 7d7bb79
1 parent 1171025
commit 7d7bb79
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 0 deletions.
diff --git a/examples/event-source-mapping/main.tf b/examples/event-source-mapping/main.tf
@@ -84,6 +84,11 @@ module "lambda_function" {
     #          }
     #        }
     #      ]
+    #      self_managed_kafka_event_source_config = [
+    #        {
+    #          consumer_group_id = "example-consumer-group"
+    #        }
+    #      ]
     #      source_access_configuration = [
     #        {
     #          type = "SASL_SCRAM_512_AUTH",

diff --git a/main.tf b/main.tf
@@ -295,6 +295,19 @@ resource "aws_lambda_event_source_mapping" "this" {
     }
   }
 
+  dynamic "self_managed_kafka_event_source_config" {
+    for_each = try(each.value.self_managed_kafka_event_source_config, [])
+    content {
+      consumer_group_id = self_managed_kafka_event_source_config.value.consumer_group_id
+    }
+  }
+  dynamic "amazon_managed_kafka_event_source_config" {
+    for_each = try(each.value.amazon_managed_kafka_event_source_config, [])
+    content {
+      consumer_group_id = amazon_managed_kafka_event_source_config.value.consumer_group_id
+    }
+  }
+
   dynamic "source_access_configuration" {
     for_each = try(each.value.source_access_configuration, [])
     content {