To setup AWS Kinesis binding create a component of type bindings.aws.kinesis
. See this guide on how to create and apply a binding configuration.
See this for instructions on how to set up an AWS Kinesis data streams See Authenticating to AWS for information about authentication-related attributes
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: <NAME>
spec:
type: bindings.aws.kinesis
version: v1
metadata:
- name: streamName
value: "KINESIS_STREAM_NAME" # Kinesis stream name
- name: consumerName
value: "KINESIS_CONSUMER_NAME" # Kinesis consumer name
- name: mode
value: "shared" # shared - Shared throughput or extended - Extended/Enhanced fanout
- name: region
value: "AWS_REGION" #replace
- name: accessKey
value: "AWS_ACCESS_KEY" # replace
- name: secretKey
value: "AWS_SECRET_KEY" #replace
- name: sessionToken
value: "*****************"
- name: direction
value: "input, output"
- name: endpoint
value: "http://localhost:4566" # Optional: Custom endpoint (e.g. for LocalStack)
Field | Required | Binding support | Details | Example |
---|---|---|---|---|
mode | N | Input | The Kinesis stream mode. shared - Shared throughput, extended - Extended/Enhanced fanout methods. More details are here. Defaults to "shared" | "shared" , "extended" |
streamName | Y | Input/Output | The AWS Kinesis Stream Name | "stream" |
consumerName | Y | Input | The AWS Kinesis Consumer Name | "myconsumer" |
region | Y | Output | The specific AWS region the AWS Kinesis instance is deployed in | "us-east-1" |
accessKey | Y | Output | The AWS Access Key to access this resource | "key" |
secretKey | Y | Output | The AWS Secret Access Key to access this resource | "secretAccessKey" |
sessionToken | N | Output | The AWS session token to use | "sessionToken" |
direction | N | Input/Output | The direction of the binding | "input" , "output" , "input, output" |
endpoint | N | Input | Custom endpoint for Kinesis and DynamoDB (for example to enable AWS LocalStack support) | "http://localhost:4566" |
This component supports both input and output binding interfaces.
This component supports output binding with the following operations:
create