default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.accessKey(String accessKey) |
Amazon AWS Access Key.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.amazonKinesisClient(com.amazonaws.services.kinesis.AmazonKinesis amazonKinesisClient) |
Amazon Kinesis client to use for all requests for this endpoint.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.autoDiscoverClient(boolean autoDiscoverClient) |
Setting the autoDiscoverClient mechanism, if true, the component will
look for a client instance in the registry automatically otherwise it
will skip that checking.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.autowiredEnabled(boolean autowiredEnabled) |
Whether autowiring is enabled.
|
static AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.awsKinesis() |
AWS Kinesis (camel-aws-kinesis)
Consume and produce records from AWS Kinesis Streams.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.configuration(org.apache.camel.component.aws.kinesis.KinesisConfiguration configuration) |
The component configuration.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.iteratorType(com.amazonaws.services.kinesis.model.ShardIteratorType iteratorType) |
Defines where in the Kinesis stream to start getting records.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.maxResultsPerRequest(int maxResultsPerRequest) |
Maximum number of records that will be fetched in each poll.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.proxyHost(String proxyHost) |
To define a proxy host when instantiating the Kinesis client.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.proxyPort(Integer proxyPort) |
To define a proxy port when instantiating the Kinesis client.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.proxyProtocol(com.amazonaws.Protocol proxyProtocol) |
To define a proxy protocol when instantiating the Kinesis client.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.region(String region) |
The region in which Kinesis client needs to work.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.secretKey(String secretKey) |
Amazon AWS Secret Key.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.sequenceNumber(String sequenceNumber) |
The sequence number to start polling from.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.shardClosed(org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum shardClosed) |
Define what will be the behavior in case of shard closed.
|
default AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder |
AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder.shardId(String shardId) |
Defines which shardId in the Kinesis stream to get records from.
|