Class: AWSCDK::Lambda::CfnEventSourceMapping::AmazonManagedKafkaEventSourceConfigProperty

Inherits:

Jsii::Struct

• Object
• Jsii::Struct
• AWSCDK::Lambda::CfnEventSourceMapping::AmazonManagedKafkaEventSourceConfigProperty

Defined in:

lambda/cfn_event_source_mapping.rb

Overview

Specific configuration settings for an Amazon Managed Streaming for Apache Kafka (Amazon MSK) event source.

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-amazonmanagedkafkaeventsourceconfig.html

Instance Attribute Summary

• #consumer_group_id ⇒ String^? readonly

  The identifier for the Kafka consumer group to join.

• #schema_registry_config ⇒ AWSCDK::IResolvable, ... readonly

  Specific configuration settings for a Kafka schema registry.

Class Method Summary

• .jsii_properties ⇒ Object

Instance Method Summary

• #initialize(consumer_group_id: nil, schema_registry_config: nil) ⇒ AmazonManagedKafkaEventSourceConfigProperty constructor

  A new instance of AmazonManagedKafkaEventSourceConfigProperty.

• #to_jsii ⇒ Object

Constructor Details

#initialize(consumer_group_id: nil, schema_registry_config: nil) ⇒ AmazonManagedKafkaEventSourceConfigProperty

Returns a new instance of AmazonManagedKafkaEventSourceConfigProperty.

Parameters:

• consumer_group_id (String, nil) (defaults to: nil) —

  The identifier for the Kafka consumer group to join.

• schema_registry_config (AWSCDK::IResolvable, AWSCDK::Lambda::CfnEventSourceMapping::SchemaRegistryConfigProperty, nil) (defaults to: nil) —

  Specific configuration settings for a Kafka schema registry.

# File 'lambda/cfn_event_source_mapping.rb', line 903

def initialize(consumer_group_id: nil, schema_registry_config: nil)
  @consumer_group_id = consumer_group_id
  Jsii::Type.check_type(@consumer_group_id, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "consumerGroupId") unless @consumer_group_id.nil?
  @schema_registry_config = schema_registry_config.is_a?(Hash) ? ::AWSCDK::Lambda::CfnEventSourceMapping::SchemaRegistryConfigProperty.new(**schema_registry_config.transform_keys(&:to_sym)) : schema_registry_config
  Jsii::Type.check_type(@schema_registry_config, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19sYW1iZGEuQ2ZuRXZlbnRTb3VyY2VNYXBwaW5nLlNjaGVtYVJlZ2lzdHJ5Q29uZmlnUHJvcGVydHkifV19fQ==")), "schemaRegistryConfig") unless @schema_registry_config.nil?
end

Instance Attribute Details

#consumer_group_id ⇒ String^? (readonly)

The identifier for the Kafka consumer group to join.

The consumer group ID must be unique among all your Kafka event sources. After creating a Kafka event source mapping with the consumer group ID specified, you cannot update this value. For more information, see Customizable consumer group ID .

Returns:

• (String, nil)

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-amazonmanagedkafkaeventsourceconfig.html#cfn-lambda-eventsourcemapping-amazonmanagedkafkaeventsourceconfig-consumergroupid

# File 'lambda/cfn_event_source_mapping.rb', line 916

def consumer_group_id
  @consumer_group_id
end

#schema_registry_config ⇒ AWSCDK::IResolvable, ... (readonly)

Specific configuration settings for a Kafka schema registry.

Returns:

• (AWSCDK::IResolvable, AWSCDK::Lambda::CfnEventSourceMapping::SchemaRegistryConfigProperty, nil)

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-amazonmanagedkafkaeventsourceconfig.html#cfn-lambda-eventsourcemapping-amazonmanagedkafkaeventsourceconfig-schemaregistryconfig

# File 'lambda/cfn_event_source_mapping.rb', line 921

def schema_registry_config
  @schema_registry_config
end

Class Method Details

.jsii_properties ⇒ Object

# File 'lambda/cfn_event_source_mapping.rb', line 923

def self.jsii_properties
  {
    :consumer_group_id => "consumerGroupId",
    :schema_registry_config => "schemaRegistryConfig",
  }
end

Instance Method Details

#to_jsii ⇒ Object

# File 'lambda/cfn_event_source_mapping.rb', line 930

def to_jsii
  result = {}
  result.merge!({
    "consumerGroupId" => @consumer_group_id,
    "schemaRegistryConfig" => @schema_registry_config,
  })
  result.compact
end