AWSTemplateFormatVersion: '2010-09-09'
Parameters: {}
Resources:
  KafkaFunction:
    Type: AWS::Serverless::Function
    Properties:
      CodeUri: s3://sam-demo-bucket/kafka.zip
      Handler: index.kafka_handler
      Runtime: python3.9
      Events:
        MyKafkaCluster:
          Type: SelfManagedKafka
          Properties:
            KafkaBootstrapServers:
            - abc.xyz.com:9092
            - 123.45.67.89:9096
            Topics:
            - Topic1
            SourceAccessConfigurations:
            - Type: CLIENT_CERTIFICATE_TLS_AUTH
              URI: !Sub arn:${AWS::Partition}:secretsmanager:us-west-2:123456789012:secret:my-path/my-secret-name-1a2b3c
            - Type: VPC_SUBNET
              URI: subnet:subnet-12345
            - Type: VPC_SECURITY_GROUP
              URI: security_group:sg-67890
            ConsumerGroupId: consumergroup1