Skip to content

Commit 2c077cb

Browse files
sergiolcSergio Correaantonbabenko
authored
feat: Add support for kafka event source config (#617)
Co-authored-by: Sergio Correa <[email protected]> Co-authored-by: Anton Babenko <[email protected]>
1 parent aa94b91 commit 2c077cb

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

modules/alias/main.tf

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -155,6 +155,20 @@ resource "aws_lambda_event_source_mapping" "this" {
155155
}
156156
}
157157

158+
dynamic "self_managed_kafka_event_source_config" {
159+
for_each = try(each.value.self_managed_kafka_event_source_config, [])
160+
content {
161+
consumer_group_id = try(self_managed_kafka_event_source_config.value.consumer_group_id, null)
162+
}
163+
}
164+
165+
dynamic "amazon_managed_kafka_event_source_config" {
166+
for_each = try(each.value.amazon_managed_kafka_event_source_config, [])
167+
content {
168+
consumer_group_id = try(amazon_managed_kafka_event_source_config.value.consumer_group_id, null)
169+
}
170+
}
171+
158172
dynamic "source_access_configuration" {
159173
for_each = try(each.value.source_access_configuration, [])
160174
content {

0 commit comments

Comments
 (0)