From 2c077cb1450af76cf44b56bfeba796ee9d9d9a00 Mon Sep 17 00:00:00 2001
From: Sergio Correa <sergiolc@hotmail.com>
Date: Sat, 5 Oct 2024 09:44:02 +0100
Subject: [PATCH] feat: Add support for kafka event source config (#617)

Co-authored-by: Sergio Correa <scorrea@dataminr.com>
Co-authored-by: Anton Babenko <anton@antonbabenko.com>
---
 modules/alias/main.tf | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/modules/alias/main.tf b/modules/alias/main.tf
index b5f24f0f..e57079a2 100644
--- a/modules/alias/main.tf
+++ b/modules/alias/main.tf
@@ -155,6 +155,20 @@ 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 = try(self_managed_kafka_event_source_config.value.consumer_group_id, null)
+    }
+  }
+
+  dynamic "amazon_managed_kafka_event_source_config" {
+    for_each = try(each.value.amazon_managed_kafka_event_source_config, [])
+    content {
+      consumer_group_id = try(amazon_managed_kafka_event_source_config.value.consumer_group_id, null)
+    }
+  }
+
   dynamic "source_access_configuration" {
     for_each = try(each.value.source_access_configuration, [])
     content {