First non-rc release of sqs2kinesis.
The application (sqs2kinesis) is used to read messages from the SQS queue and send them to the Kinesis stream using a back-pressured mechanism.
The application.conf
file is used to set it up:
sqs2kinesis {
sqs-queue = {sqs-queue-url}
kinesis-stream-name = {kinesis-stream-name}
}
This is a Scala application, so you could either run it via java -jar
or using docker.
The docker image is here