PutKinesisStream

PutKinesisStream 2.6.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.
Tags: amazon, aws, kinesis, put, stream
Input Requirement: REQUIRED
Supports Sensitive Dynamic Properties: false

Properties

AWS Credentials Provider service
The Controller Service that is used to obtain AWS credentials provider

Display Name

AWS Credentials Provider service

Description

The Controller Service that is used to obtain AWS credentials provider

API Name

AWS Credentials Provider service

Service Interface

org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderService

Service Implementations

org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderControllerService

Expression Language Scope

Not Supported

Sensitive

false

Required

true
Communications Timeout

Display Name

Communications Timeout

Description

API Name

Communications Timeout

Default Value

30 secs

Expression Language Scope

Not Supported

Sensitive

false

Required

true
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.

Display Name

Endpoint Override URL

Description

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.

API Name

Endpoint Override URL

Expression Language Scope

Environment variables defined at JVM level and system properties

Sensitive

false

Required

false
Max Message Buffer Size
Max message buffer size defined with standard data size units

Display Name

Max Message Buffer Size

Description

Max message buffer size defined with standard data size units

API Name

Max Message Buffer Size

Default Value

1 MB

Expression Language Scope

Not Supported

Sensitive

false

Required

false
Message Batch Size
Batch size for messages (1-500).

Display Name

Message Batch Size

Description

Batch size for messages (1-500).

API Name

Message Batch Size

Default Value

250

Expression Language Scope

Not Supported

Sensitive

false

Required

false
Proxy Configuration Service
Specifies the Proxy Configuration Controller Service to proxy network requests.

Display Name

Proxy Configuration Service

Description

Specifies the Proxy Configuration Controller Service to proxy network requests.

API Name

proxy-configuration-service

Service Interface

org.apache.nifi.proxy.ProxyConfigurationService

Service Implementations

org.apache.nifi.proxy.StandardProxyConfigurationService

Expression Language Scope

Not Supported

Sensitive

false

Required

false
Region
Display Name

Region

Description

API Name

Region

Default Value

us-west-2

Allowable Values
- AWS GovCloud (US-East)
- AWS GovCloud (US-West)
- Africa (Cape Town)
- Asia Pacific (Hong Kong)
- Asia Pacific (Hyderabad)
- Asia Pacific (Jakarta)
- Asia Pacific (Malaysia)
- Asia Pacific (Melbourne)
- Asia Pacific (Mumbai)
- Asia Pacific (New Zealand)
- Asia Pacific (Osaka)
- Asia Pacific (Seoul)
- Asia Pacific (Singapore)
- Asia Pacific (Sydney)
- Asia Pacific (Taipei)
- Asia Pacific (Thailand)
- Asia Pacific (Tokyo)
- Canada (Central)
- Canada West (Calgary)
- China (Beijing)
- China (Ningxia)
- EU (Germany)
- EU ISOE West
- Europe (Frankfurt)
- Europe (Ireland)
- Europe (London)
- Europe (Milan)
- Europe (Paris)
- Europe (Spain)
- Europe (Stockholm)
- Europe (Zurich)
- Israel (Tel Aviv)
- Mexico (Central)
- Middle East (Bahrain)
- Middle East (UAE)
- South America (Sao Paulo)
- US East (N. Virginia)
- US East (Ohio)
- US ISO East
- US ISO WEST
- US ISOB East (Ohio)
- US ISOF EAST
- US ISOF SOUTH
- US West (N. California)
- US West (Oregon)
- aws global region
- aws-cn global region
- aws-iso global region
- aws-iso-b global region
- aws-iso-e global region
- aws-iso-f global region
- aws-us-gov global region
Expression Language Scope

Not Supported

Sensitive

false

Required

true
Stream Name
The name of Kinesis Stream

Display Name

Stream Name

Description

The name of Kinesis Stream

API Name

Stream Name

Expression Language Scope

Environment variables and FlowFile Attributes

Sensitive

false

Required

true
Stream Partition Key
The partition key attribute. If it is not set, a random value is used

Display Name

Stream Partition Key

Description

The partition key attribute. If it is not set, a random value is used

API Name

Stream Partition Key

Default Value

${kinesis.partition.key}

Expression Language Scope

Environment variables and FlowFile Attributes

Sensitive

false

Required

false

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