PutKinesisStream 2.3.0¶
BUNDLE¶
org.apache.nifi | nifi-aws-nar
DESCRIPTION¶
Sends the contents to a specified Amazon Kinesis. In order to send data to Kinesis, the stream name has to be specified.
INPUT REQUIREMENT¶
REQUIRED
Supports Sensitive Dynamic Properties¶
false
PROPERTIES¶
Property |
Description |
|---|---|
AWS Credentials Provider service |
The Controller Service that is used to obtain AWS credentials provider |
Communications Timeout |
|
Endpoint Override URL |
Endpoint URL to use instead of the AWS default including scheme, host, port, and path. The AWS libraries select an endpoint URL based on the AWS region, but this property overrides the selected endpoint URL, allowing use with other S3-compatible endpoints. |
Region |
|
amazon-kinesis-stream-partition-key |
The partition key attribute. If it is not set, a random value is used |
kinesis-stream-name |
The name of Kinesis Stream |
max-message-buffer-size |
Max message buffer size in Mega-bytes |
message-batch-size |
Batch size for messages (1-500). |
proxy-configuration-service |
Specifies the Proxy Configuration Controller Service to proxy network requests. Supported proxies: HTTP + AuthN |
RELATIONSHIPS¶
NAME |
DESCRIPTION |
|---|---|
failure |
FlowFiles are routed to failure relationship |
success |
FlowFiles are routed to success relationship |
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 |
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 |