Package software.amazon.awscdk.services.lambda.eventsources

Class SelfManagedKafkaEventSourceProps.Jsii$Proxy

java.lang.Object

software.amazon.jsii.JsiiObject

software.amazon.awscdk.services.lambda.eventsources.SelfManagedKafkaEventSourceProps.Jsii$Proxy

All Implemented Interfaces:

BaseStreamEventSourceProps, KafkaEventSourceProps, SelfManagedKafkaEventSourceProps, software.amazon.jsii.JsiiSerializable

Enclosing interface:

SelfManagedKafkaEventSourceProps

@Stability(Stable)
@Internal
public static final class SelfManagedKafkaEventSourceProps.Jsii$Proxy
extends software.amazon.jsii.JsiiObject
implements SelfManagedKafkaEventSourceProps

An implementation for SelfManagedKafkaEventSourceProps

Nested Class Summary

Nested classes/interfaces inherited from class software.amazon.jsii.JsiiObject

software.amazon.jsii.JsiiObject.InitializationMode

Nested classes/interfaces inherited from interface software.amazon.awscdk.services.lambda.eventsources.SelfManagedKafkaEventSourceProps

SelfManagedKafkaEventSourceProps.Builder, SelfManagedKafkaEventSourceProps.Jsii$Proxy

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Jsii$Proxy(SelfManagedKafkaEventSourceProps.Builder builder)	Constructor that initializes the object based on literal property values passed by the SelfManagedKafkaEventSourceProps.Builder.
protected	Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef)	Constructor that initializes the object based on values retrieved from the JsiiObject.

Method Summary

Modifier and Type	Method	Description
com.fasterxml.jackson.databind.JsonNode	$jsii$toJson()
final boolean	equals(Object o)
final AuthenticationMethod	getAuthenticationMethod()	The authentication method for your Kafka cluster.
final Number	getBatchSize()	The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.
final List<String>	getBootstrapServers()	The list of host and port pairs that are the addresses of the Kafka brokers in a "bootstrap" Kafka cluster that a Kafka client connects to initially to bootstrap itself.
final String	getConsumerGroupId()	The identifier for the Kafka consumer group to join.
final Boolean	getEnabled()	If the stream event source mapping should be enabled.
final IKey	getFilterEncryption()	Add Customer managed KMS key to encrypt Filter Criteria.
final List<Map<String,Object>>	getFilters()	Add filter criteria to Event Source.
final Duration	getMaxBatchingWindow()	The maximum amount of time to gather records before invoking the function.
final IEventSourceDlq	getOnFailure()	Add an on Failure Destination for this Kafka event.
final ProvisionedPollerConfig	getProvisionedPollerConfig()	Configuration for provisioned pollers that read from the event source.
final ISecret	getRootCACertificate()	The secret with the root CA certificate used by your Kafka brokers for TLS encryption This field is required if your Kafka brokers use certificates signed by a private CA.
final ISchemaRegistry	getSchemaRegistryConfig()	Specific configuration settings for a Kafka schema registry.
final ISecret	getSecret()	The secret with the Kafka credentials, see https://docs.aws.amazon.com/msk/latest/developerguide/msk-password.html for details This field is required if your Kafka brokers are accessed over the Internet.
final ISecurityGroup	getSecurityGroup()	If your Kafka brokers are only reachable via VPC, provide the security group here.
final StartingPosition	getStartingPosition()	Where to begin consuming the stream.
final Number	getStartingPositionTimestamp()	The time from which to start reading, in Unix time seconds.
final String	getTopic()	The Kafka topic to subscribe to.
final IVpc	getVpc()	If your Kafka brokers are only reachable via VPC provide the VPC here.
final SubnetSelection	getVpcSubnets()	If your Kafka brokers are only reachable via VPC, provide the subnets selection here.
final int	hashCode()

Methods inherited from class software.amazon.jsii.JsiiObject

jsiiAsyncCall, jsiiAsyncCall, jsiiCall, jsiiCall, jsiiGet, jsiiGet, jsiiSet, jsiiStaticCall, jsiiStaticCall, jsiiStaticGet, jsiiStaticGet, jsiiStaticSet, jsiiStaticSet

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Jsii$Proxy

protected Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef)

Constructor that initializes the object based on values retrieved from the JsiiObject.

Parameters:

objRef - Reference to the JSII managed object.

Jsii$Proxy

protected Jsii$Proxy(SelfManagedKafkaEventSourceProps.Builder builder)

Constructor that initializes the object based on literal property values passed by the SelfManagedKafkaEventSourceProps.Builder.

Method Details

getBootstrapServers

public final List<String> getBootstrapServers()

Description copied from interface: SelfManagedKafkaEventSourceProps

The list of host and port pairs that are the addresses of the Kafka brokers in a "bootstrap" Kafka cluster that a Kafka client connects to initially to bootstrap itself.

They are in the format abc.xyz.com:xxxx.

Specified by:

getBootstrapServers in interface SelfManagedKafkaEventSourceProps

getAuthenticationMethod

public final AuthenticationMethod getAuthenticationMethod()

Description copied from interface: SelfManagedKafkaEventSourceProps

The authentication method for your Kafka cluster.

Default: AuthenticationMethod.SASL_SCRAM_512_AUTH

Specified by:

getAuthenticationMethod in interface SelfManagedKafkaEventSourceProps

getRootCACertificate

public final ISecret getRootCACertificate()

Description copied from interface: SelfManagedKafkaEventSourceProps

The secret with the root CA certificate used by your Kafka brokers for TLS encryption This field is required if your Kafka brokers use certificates signed by a private CA.

Default: - none

Specified by:

getRootCACertificate in interface SelfManagedKafkaEventSourceProps

getSecurityGroup

public final ISecurityGroup getSecurityGroup()

Description copied from interface: SelfManagedKafkaEventSourceProps

If your Kafka brokers are only reachable via VPC, provide the security group here.

Default: - none, required if setting vpc

Specified by:

getSecurityGroup in interface SelfManagedKafkaEventSourceProps

getVpc

public final IVpc getVpc()

Description copied from interface: SelfManagedKafkaEventSourceProps

If your Kafka brokers are only reachable via VPC provide the VPC here.

Default: none

Specified by:

getVpc in interface SelfManagedKafkaEventSourceProps

getVpcSubnets

public final SubnetSelection getVpcSubnets()

Description copied from interface: SelfManagedKafkaEventSourceProps

If your Kafka brokers are only reachable via VPC, provide the subnets selection here.

Default: - none, required if setting vpc

Specified by:

getVpcSubnets in interface SelfManagedKafkaEventSourceProps

getTopic

public final String getTopic()

Description copied from interface: KafkaEventSourceProps

The Kafka topic to subscribe to.

Specified by:

getTopic in interface KafkaEventSourceProps

getConsumerGroupId

public final String getConsumerGroupId()

Description copied from interface: KafkaEventSourceProps

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. The value must have a length between 1 and 200 and full the pattern '[a-zA-Z0-9-/:_+=.@-]'.

Default: - none

Specified by:

getConsumerGroupId in interface KafkaEventSourceProps

See Also:

• https://docs.aws.amazon.com/lambda/latest/dg/with-msk.html#services-msk-consumer-group-id

getFilterEncryption

public final IKey getFilterEncryption()

Description copied from interface: KafkaEventSourceProps

Add Customer managed KMS key to encrypt Filter Criteria.

Default: - none

Specified by:

getFilterEncryption in interface KafkaEventSourceProps

See Also:

• https://docs.aws.amazon.com/kms/latest/developerguide/concepts.html#aws-managed-cmk

getFilters

public final List<Map<String,Object>> getFilters()

Description copied from interface: KafkaEventSourceProps

Add filter criteria to Event Source.

Default: - none

Specified by:

getFilters in interface KafkaEventSourceProps

See Also:

• https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html

getOnFailure

public final IEventSourceDlq getOnFailure()

Description copied from interface: KafkaEventSourceProps

Add an on Failure Destination for this Kafka event.

SNS/SQS/S3 are supported

Default: - discarded records are ignored

Specified by:

getOnFailure in interface KafkaEventSourceProps

getSchemaRegistryConfig

public final ISchemaRegistry getSchemaRegistryConfig()

Description copied from interface: KafkaEventSourceProps

Specific configuration settings for a Kafka schema registry.

Default: - none

Specified by:

getSchemaRegistryConfig in interface KafkaEventSourceProps

getSecret

public final ISecret getSecret()

Description copied from interface: KafkaEventSourceProps

The secret with the Kafka credentials, see https://docs.aws.amazon.com/msk/latest/developerguide/msk-password.html for details This field is required if your Kafka brokers are accessed over the Internet.

Default: none

Specified by:

getSecret in interface KafkaEventSourceProps

getStartingPositionTimestamp

public final Number getStartingPositionTimestamp()

Description copied from interface: KafkaEventSourceProps

The time from which to start reading, in Unix time seconds.

Default: - no timestamp

Specified by:

getStartingPositionTimestamp in interface KafkaEventSourceProps

getStartingPosition

public final StartingPosition getStartingPosition()

Description copied from interface: BaseStreamEventSourceProps

Where to begin consuming the stream.

Specified by:

getStartingPosition in interface BaseStreamEventSourceProps

getBatchSize

public final Number getBatchSize()

Description copied from interface: BaseStreamEventSourceProps

The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.

Your function receives an event with all the retrieved records.

Valid Range:

• Minimum value of 1
• Maximum value of:
  • 1000 for DynamoEventSource
  • 10000 for KinesisEventSource, ManagedKafkaEventSource and SelfManagedKafkaEventSource

Default: 100

Specified by:

getBatchSize in interface BaseStreamEventSourceProps

getEnabled

public final Boolean getEnabled()

Description copied from interface: BaseStreamEventSourceProps

If the stream event source mapping should be enabled.

Default: true

Specified by:

getEnabled in interface BaseStreamEventSourceProps

getMaxBatchingWindow

public final Duration getMaxBatchingWindow()

Description copied from interface: BaseStreamEventSourceProps

The maximum amount of time to gather records before invoking the function.

Maximum of Duration.minutes(5).

Default: - Duration.seconds(0) for Kinesis, DynamoDB, and SQS event sources, Duration.millis(500) for MSK, self-managed Kafka, and Amazon MQ.

Specified by:

getMaxBatchingWindow in interface BaseStreamEventSourceProps

See Also:

• https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventsourcemapping.html#invocation-eventsourcemapping-batching

getProvisionedPollerConfig

public final ProvisionedPollerConfig getProvisionedPollerConfig()

Description copied from interface: BaseStreamEventSourceProps

Configuration for provisioned pollers that read from the event source.

When specified, allows control over the minimum and maximum number of pollers that can be provisioned to process events from the source.

Default: - no provisioned pollers

Specified by:

getProvisionedPollerConfig in interface BaseStreamEventSourceProps

$jsii$toJson

@Internal
public com.fasterxml.jackson.databind.JsonNode $jsii$toJson()

Specified by:

$jsii$toJson in interface software.amazon.jsii.JsiiSerializable

equals

public final boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public final int hashCode()

Overrides:

hashCode in class Object