public class KinesisConnectionInfo extends Object implements Serializable
| Constructor and Description |
|---|
KinesisConnectionInfo(com.amazonaws.auth.AWSCredentialsProvider credentialsProvider,
com.amazonaws.ClientConfiguration clientConfiguration,
com.amazonaws.regions.Regions region,
Integer recordsLimit)
Create a new Kinesis connection info.
|
| Modifier and Type | Method and Description |
|---|---|
com.amazonaws.ClientConfiguration |
getClientConfiguration() |
com.amazonaws.auth.AWSCredentialsProvider |
getCredentialsProvider() |
Integer |
getRecordsLimit() |
com.amazonaws.regions.Regions |
getRegion() |
String |
toString() |
public KinesisConnectionInfo(com.amazonaws.auth.AWSCredentialsProvider credentialsProvider,
com.amazonaws.ClientConfiguration clientConfiguration,
com.amazonaws.regions.Regions region,
Integer recordsLimit)
Create a new Kinesis connection info.
credentialsProvider - implementation to provide credentials to connect to kinesisclientConfiguration - client configuration to pass to kinesis clientregion - region to connect torecordsLimit - max records to be fetched in a getRecords request to kinesispublic Integer getRecordsLimit()
public com.amazonaws.auth.AWSCredentialsProvider getCredentialsProvider()
public com.amazonaws.ClientConfiguration getClientConfiguration()
public com.amazonaws.regions.Regions getRegion()
Copyright © 2021 The Apache Software Foundation. All rights reserved.