Merge branch 'terraform-aws-modules:master' into lambda-fix-plus-another

Author: soisyourface

CHANGELOG.md

@@ -2,6 +2,20 @@
 
 All notable changes to this project will be documented in this file.
 
+## [3.14.1](https://github.com/terraform-aws-modules/terraform-aws-eventbridge/compare/v3.14.0...v3.14.1) (2025-01-08)
+
+
+### Bug Fixes
+
+* Cloudwatch policy for pipes ([#140](https://github.com/terraform-aws-modules/terraform-aws-eventbridge/issues/140)) ([57626e4](https://github.com/terraform-aws-modules/terraform-aws-eventbridge/commit/57626e4826fee0fa3969d706aa54285f24b81bdd))
+
+## [3.14.0](https://github.com/terraform-aws-modules/terraform-aws-eventbridge/compare/v3.13.0...v3.14.0) (2025-01-07)
+
+
+### Features
+
+* Added dynamic block for managed_streaming_kafka_parameters ([#148](https://github.com/terraform-aws-modules/terraform-aws-eventbridge/issues/148)) ([7621d52](https://github.com/terraform-aws-modules/terraform-aws-eventbridge/commit/7621d52f7143c8f142bc2f8ab0093d6653e4907f))
+
 ## [3.13.0](https://github.com/terraform-aws-modules/terraform-aws-eventbridge/compare/v3.12.0...v3.13.0) (2024-11-27)
 
 

iam_pipes.tf

@@ -60,7 +60,16 @@ locals {
           matching_services = ["batch"]
         },
         logs = {
-          values            = [v.target],
+          values = flatten([
+            "${v.target}:*",
+            [
+              for pipe in var.pipes : [
+                for log_config in try([pipe.log_configuration], []) : [
+                  for cloudwatch_log in try([log_config.cloudwatch_logs_log_destination], []) : "${cloudwatch_log.log_group_arn}:*"
+                ]
+              ]
+            ]
+          ]),
           matching_services = ["logs"]
         },
         ecs = {

main.tf

@@ -679,6 +679,27 @@ resource "aws_pipes_pipe" "this" {
         }
       }
 
+      dynamic "managed_streaming_kafka_parameters" {
+        for_each = try([source_parameters.value.managed_streaming_kafka_parameters], [])
+
+        content {
+          batch_size                         = try(managed_streaming_kafka_parameters.value.batch_size, null)
+          maximum_batching_window_in_seconds = try(managed_streaming_kafka_parameters.value.maximum_batching_window_in_seconds, null)
+          consumer_group_id                  = try(managed_streaming_kafka_parameters.value.consumer_group_id, null)
+          starting_position                  = try(managed_streaming_kafka_parameters.value.starting_position, null)
+          topic_name                         = try(managed_streaming_kafka_parameters.value.topic_name, null)
+
+          dynamic "credentials" {
+            for_each = try([managed_streaming_kafka_parameters.value.credentials], [])
+
+            content {
+              client_certificate_tls_auth = credentials.value.client_certificate_tls_auth
+              sasl_scram_512_auth = credentials.value.sasl_scram_512_auth
+            }
+          }
+        }
+      }
+
       dynamic "kinesis_stream_parameters" {
         for_each = try([source_parameters.value.kinesis_stream_parameters], [])