Description:
Sends the contents to a specified Amazon Kinesis. In order to send data to Kinesis, the stream name has to be specified.
Tags:
amazon, aws, kinesis, put, stream
Properties:
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 nifi.properties file has an entry for the property nifi.sensitive.props.key.
| 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  us-east-1 us-west-1 us-west-2 eu-west-1 eu-central-1 ap-southeast-1 ap-southeast-2 ap-northeast-1 ap-northeast-2 sa-east-1 cn-north-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 | Controller Service API: AWSCredentialsProviderService Implementation: AWSCredentialsProviderControllerService | 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 |
Relationships:
| 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 |
| aws.kinesis.shard.id | Shard id of the message posted to AWS Kinesis |
State management:
This component does not store state.
Restricted:
This component is not restricted.