class Amazonite::Lambda::SelfManagedEventSource

Overview

The self-managed Apache Kafka cluster for your event source.

Included Modules

Defined in:

lambda/self_managed_event_source.cr

Constructors

Instance Method Summary

Constructor Detail

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

[View source]
def self.new(endpoints : Hash(EndPointType, Array(String)) | Nil = nil) #

[View source]
def self.new(*, __pull_for_json_serializable pull : JSON::PullParser) #

[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 endpoints : Hash(EndPointType, Array(String)) | Nil #

The list of bootstrap servers for your Kafka brokers in the following format: "KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].


[View source]
def endpoints=(endpoints : Hash(EndPointType, Array(String)) | Nil) #

The list of bootstrap servers for your Kafka brokers in the following format: "KAFKA_BOOTSTRAP_SERVERS": ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].


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

See Object#hash(hasher)


def validate! : Nil #

[View source]