public final class KinesisIngressSpec<T> extends java.lang.Object implements IngressSpec<T>
Modifier and Type | Method and Description |
---|---|
AwsCredentials |
awsCredentials() |
AwsRegion |
awsRegion() |
java.util.Properties |
clientConfigurationProperties() |
KinesisIngressDeserializer<T> |
deserializer() |
IngressIdentifier<T> |
id()
Returns the unique identifier of the ingress.
|
KinesisIngressStartupPosition |
startupPosition() |
java.util.List<java.lang.String> |
streams() |
IngressType |
type()
Returns the type of the ingress.
|
public IngressIdentifier<T> id()
IngressSpec
id
in interface IngressSpec<T>
public IngressType type()
IngressSpec
type
in interface IngressSpec<T>
public java.util.List<java.lang.String> streams()
public KinesisIngressDeserializer<T> deserializer()
public KinesisIngressStartupPosition startupPosition()
public AwsRegion awsRegion()
public AwsCredentials awsCredentials()
public java.util.Properties clientConfigurationProperties()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.