Sends the contents to a specified Amazon Kinesis. In order to send data to Kinesis, the stream name has to be specified.


amazon, aws, kinesis, put, stream

In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the Expression Language Guide, and whether a property is considered “sensitive”, meaning that its value will be encrypted. Before entering a value in a sensitive property, ensure that the file has an entry for the property nifi.sensitive.props.key.

Controller Service API: AWSCredentialsProviderService Implementation: AWSCredentialsProviderControllerService
Name Default Value Allowable Values Description
Amazon Kinesis Stream Name The name of Kinesis Stream
Amazon Kinesis Stream Partition Key The partition key attribute. If it is not set, a random value is used
Supports Expression Language: true
Message Batch Size 250 Batch size for messages (1-500).
Max message buffer size (MB) 1 MB Max message buffer size in Mega-bytes
Region us-west-2 us-gov-west-1
No Description Provided.
Access Key No Description Provided.
Sensitive Property: true
Supports Expression Language: true
Secret Key No Description Provided.
Sensitive Property: true
Supports Expression Language: true
AWS Credentials Provider service Path to a file containing AWS access key and secret key in properties file format.
Communications Timeout 30 secs No Description Provided.
Proxy Host Proxy host name or IP
Supports Expression Language: true
Proxy Host Port Proxy host port
Supports Expression Language: true


Name Description
success FlowFiles are routed to success relationship
failure FlowFiles are routed to failure relationship

Reads Attributes:

None specified.

Writes Attributes:

Name Description
aws.kinesis.error.message Error message on posting message to AWS Kinesis
aws.kinesis.error.code Error code for the message when posting to AWS Kinesis
ignite.cache.batch.flow.file.successful.number The successful FlowFile item number
aws.kinesis.sequence.number Sequence number for the message when posting to AWS Kinesis Shard id of the message posted to AWS Kinesis

State management:

This component does not store state.


This component is not restricted.