default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.accessKey(String accessKey) |
Amazon AWS Access Key.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.amazonKinesisClient(software.amazon.awssdk.services.kinesis.KinesisClient amazonKinesisClient) |
Amazon Kinesis client to use for all requests for this endpoint.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.autowiredEnabled(boolean autowiredEnabled) |
Whether autowiring is enabled.
|
static Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.aws2Kinesis() |
AWS 2 Kinesis (camel-aws2-kinesis)
Consume and produce records from and to AWS Kinesis Streams using AWS SDK
version 2.x.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.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 Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.cborEnabled(boolean cborEnabled) |
This option will set the CBOR_ENABLED property during the execution.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.configuration(org.apache.camel.component.aws2.kinesis.Kinesis2Configuration configuration) |
Component configuration.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.iteratorType(software.amazon.awssdk.services.kinesis.model.ShardIteratorType iteratorType) |
Defines where in the Kinesis stream to start getting records.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.maxResultsPerRequest(int maxResultsPerRequest) |
Maximum number of records that will be fetched in each poll.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.proxyHost(String proxyHost) |
To define a proxy host when instantiating the Kinesis client.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.proxyPort(Integer proxyPort) |
To define a proxy port when instantiating the Kinesis client.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.proxyProtocol(software.amazon.awssdk.core.Protocol proxyProtocol) |
To define a proxy protocol when instantiating the Kinesis client.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.region(String region) |
The region in which Kinesis Firehose client needs to work.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.secretKey(String secretKey) |
Amazon AWS Secret Key.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.sequenceNumber(String sequenceNumber) |
The sequence number to start polling from.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.shardClosed(org.apache.camel.component.aws2.kinesis.Kinesis2ShardClosedStrategyEnum shardClosed) |
Define what will be the behavior in case of shard closed.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.shardId(String shardId) |
Defines which shardId in the Kinesis stream to get records from.
|
default Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder |
Aws2KinesisComponentBuilderFactory.Aws2KinesisComponentBuilder.trustAllCertificates(boolean trustAllCertificates) |
If we want to trust all certificates in case of overriding the
endpoint.
|