public static final class SelfManagedKafkaEventSourceProps.Jsii$Proxy extends software.amazon.jsii.JsiiObject implements SelfManagedKafkaEventSourceProps
SelfManagedKafkaEventSourceProps
SelfManagedKafkaEventSourceProps.Builder, SelfManagedKafkaEventSourceProps.Jsii$Proxy
Modifier | Constructor and Description |
---|---|
protected |
Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef)
Constructor that initializes the object based on values retrieved from the JsiiObject.
|
Modifier and Type | Method and Description |
---|---|
com.fasterxml.jackson.databind.JsonNode |
$jsii$toJson() |
boolean |
equals(java.lang.Object o) |
AuthenticationMethod |
getAuthenticationMethod()
The authentication method for your Kafka cluster.
|
java.lang.Number |
getBatchSize()
The largest number of records that AWS Lambda will retrieve from your event source at the time of invoking your function.
|
java.util.List<java.lang.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.
|
java.lang.Boolean |
getEnabled()
If the stream event source mapping should be enabled.
|
Duration |
getMaxBatchingWindow()
The maximum amount of time to gather records before invoking the function.
|
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.
|
ISecurityGroup |
getSecurityGroup()
If your Kafka brokers are only reachable via VPC, provide the security group here.
|
StartingPosition |
getStartingPosition()
Where to begin consuming the stream.
|
java.lang.String |
getTopic()
The Kafka topic to subscribe to.
|
IVpc |
getVpc()
If your Kafka brokers are only reachable via VPC provide the VPC here.
|
SubnetSelection |
getVpcSubnets()
If your Kafka brokers are only reachable via VPC, provide the subnets selection here.
|
int |
hashCode() |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
builder
protected Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef)
objRef
- Reference to the JSII managed object.public final java.util.List<java.lang.String> getBootstrapServers()
SelfManagedKafkaEventSourceProps
They are in the format abc.xyz.com:xxxx
.
getBootstrapServers
in interface SelfManagedKafkaEventSourceProps
public final AuthenticationMethod getAuthenticationMethod()
SelfManagedKafkaEventSourceProps
Default: AuthenticationMethod.SASL_SCRAM_512_AUTH
getAuthenticationMethod
in interface SelfManagedKafkaEventSourceProps
public final ISecurityGroup getSecurityGroup()
SelfManagedKafkaEventSourceProps
Default: - none, required if setting vpc
getSecurityGroup
in interface SelfManagedKafkaEventSourceProps
public final IVpc getVpc()
SelfManagedKafkaEventSourceProps
Default: none
getVpc
in interface SelfManagedKafkaEventSourceProps
public final SubnetSelection getVpcSubnets()
SelfManagedKafkaEventSourceProps
Default: - none, required if setting vpc
getVpcSubnets
in interface SelfManagedKafkaEventSourceProps
public final java.lang.String getTopic()
KafkaEventSourceProps
getTopic
in interface KafkaEventSourceProps
public final ISecret getSecret()
KafkaEventSourceProps
Default: none
getSecret
in interface KafkaEventSourceProps
public final StartingPosition getStartingPosition()
BaseStreamEventSourceProps
getStartingPosition
in interface BaseStreamEventSourceProps
public final java.lang.Number getBatchSize()
BaseStreamEventSourceProps
Your function receives an event with all the retrieved records.
Valid Range:
Default: 100
getBatchSize
in interface BaseStreamEventSourceProps
public final java.lang.Boolean getEnabled()
BaseStreamEventSourceProps
Default: true
getEnabled
in interface BaseStreamEventSourceProps
public final Duration getMaxBatchingWindow()
BaseStreamEventSourceProps
Maximum of Duration.minutes(5)
Default: Duration.seconds(0)
getMaxBatchingWindow
in interface BaseStreamEventSourceProps
public com.fasterxml.jackson.databind.JsonNode $jsii$toJson()
public final boolean equals(java.lang.Object o)
public final int hashCode()