public static final class KafkaEventSourceProps.Jsii$Proxy extends software.amazon.jsii.JsiiObject implements KafkaEventSourceProps
KafkaEventSourceProps
KafkaEventSourceProps.Builder, KafkaEventSourceProps.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) |
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.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.
|
StartingPosition |
getStartingPosition()
Where to begin consuming the stream.
|
java.lang.String |
getTopic()
The Kafka topic to subscribe to.
|
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.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()