Description:
Sends the contents to a specified Amazon Kinesis Firehose. In order to send data to firehose, the firehose delivery stream name has to be specified.
Tags:
amazon, aws, firehose, 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 Firehose Delivery Stream Name | The name of kinesis firehose delivery stream | ||
| Batch Size | 250 | Batch size for messages (1-500). | |
| Max message buffer size | 1 MB | Max message buffer | |
| 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 * 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 |
||
| Credentials File | No Description Provided. | ||
| AWS Credentials Provider service |
Controller Service API: AWSCredentialsProviderService Implementation: AWSCredentialsProviderControllerService |
The Controller Service that is used to obtain aws credentials provider | |
| 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 |
| failure | FlowFiles are routed to failure relationship |
| success | FlowFiles are routed to success relationship |
Reads Attributes:
None specified.
Writes Attributes:
| Name | Description |
| aws.kinesis.firehose.error.message | Error message on posting message to AWS Kinesis Firehose |
| aws.kinesis.firehose.error.code | Error code for the message when posting to AWS Kinesis Firehose |
| aws.kinesis.firehose.record.id | Record id of the message posted to Kinesis Firehose |