class Amazonite::Lambda::AmazonManagedKafkaEventSourceConfig

Overview

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

Included Modules

Defined in:

lambda/amazon_managed_kafka_event_source_config.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(pull : JSON::PullParser) #

[View source]
def self.new(consumer_group_id : String | Nil = nil, schema_registry_config : KafkaSchemaRegistryConfig | Nil = nil) #

[View source]

Instance Method Detail

def ==(other : self) #
Description copied from class Reference

Returns true if this reference is the same as other. Invokes same?.


def consumer_group_id : String | Nil #

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.


[View source]
def consumer_group_id=(consumer_group_id : String | Nil) #

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.


[View source]
def hash(hasher) #
Description copied from class Reference

See Object#hash(hasher)


def schema_registry_config : KafkaSchemaRegistryConfig | Nil #

Specific configuration settings for a Kafka schema registry.


[View source]
def schema_registry_config=(schema_registry_config : KafkaSchemaRegistryConfig | Nil) #

Specific configuration settings for a Kafka schema registry.


[View source]
def validate! : Nil #

[View source]