Consume 
Consume
yaml
type: "io.kestra.plugin.aws.kinesis.Consume"Examples
yaml
id: kinesis_consume
namespace: company.team
tasks:
- id: consume
type: io.kestra.plugin.aws.kinesis.Consume
accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
region: "eu-central-1"
streamName: "stream"
iteratorType: TRIM_HORIZON
pollDuration: PT5S
maxRecords: 100
Properties
streamName *Requiredstring
accessKeyId string
compatibilityMode booleanstring
endpointOverride string
forcePathStyle booleanstring
iteratorType string
Default
LATESTPossible Values
AT_SEQUENCE_NUMBERAFTER_SEQUENCE_NUMBERTRIM_HORIZONLATESTAT_TIMESTAMPmaxDuration string
Default
PT30SmaxRecords integerstring
Default
1000pollDuration string
Default
PT1Sregion string
secretKeyId string
sessionToken string
startingSequenceNumber string
stsEndpointOverride string
stsRoleArn string
stsRoleExternalId string
stsRoleSessionDuration string
Default
PT15MstsRoleSessionName string
Outputs
count integer
Default
0lastSequencePerShard object
SubTypestring
uri string
Format
uri
