Questions tagged with Amazon Kinesis
Content language: English
Select up to 5 tags to filter
Sort by most recent
Browse through the questions and answers listed below or filter and sort to narrow down your results.
I am using KCL 1.14.8 for Java. My Kinesis only have one shard, and I put a record into Kinesis every 30 seconds. For each record, the RecordProcessor will process it, processing each record may take...
0
answers
0
votes
120
views
asked 2 years agolg...
I am hoping to create a stream of messages, and the stream will be defined by providing an S3 bucket + prefix, and will stream:
1. a list of all existing objects at the given prefix
2. new objects...
0
answers
0
votes
139
views
asked 2 years agolg...
I am consuming Amazon Connect CTRs through Amazon Kinesis and inserting my data into Postgres. I am facing very unexpected behavior from Kinesis and Lambda function. Whenever a CTR record comes...
2
answers
0
votes
303
views
asked 2 years agolg...
Hi,
I am working on a system that uses kinesis to ingest data, this data is then processed by a lambda function and kinesis delivery stream. We have CloudWatch alarms set up that trigger if the...
1
answers
0
votes
2358
views
asked 2 years agolg...
When hooking up a lambda to a kinesis stream, the event source can choose a starting position. Settings like TRIM_HORIZON and timestamps allow to replay data that is already in the stream. When using...
1
answers
0
votes
1656
views
asked 2 years agolg...
Hi.
I have followed the instructions to the letter in the YouTube video that Paul Shiner did, and am getting the error:
[INFO ] [24-07-2022 18:22:56:030.560 GMT] Using region: eu-west-2
[INFO ]...
2
answers
1
votes
347
views
asked 2 years agolg...
When using Kinesis firehose to opensearch / elasticsearch, while the delivery stream is super convenient, one major limitation I find is that one cannot override the timestamp field that is use to...
0
answers
0
votes
118
views
asked 2 years agolg...
Changing the value of the integration mapping results in bad kinesis input.
1
answers
0
votes
508
views
asked 2 years agolg...
I am trying to connect Neptune and OpenSearch, i have 1 main problem to address.
1)we have 2 clusters of neptune, each rebuild themselves with newdata everyday so everyday we get a new graph, how do i...
1
answers
0
votes
888
views
asked 2 years agolg...
I've got a client writing JSON to a Kinesis Stream with an S3 Firehose Destination. The resulting files have multiple JSON documents within (eg. {"data": "JSON Payload 1"}{"data": "JSON Payload...
2
answers
0
votes
1545
views
asked 2 years agolg...
Hi All,
I have a simple putRecordsRequest to Kinesis using the AWS SDK. I am running this code as a load generator in conjunction with TPS Generator to perform some load testing. When doing the load...
1
answers
0
votes
539
views
asked 2 years agolg...
Given a producer sending records to a stream by calling the `PutRecord` action, is there any way to enforce that the producer is calling `PutRecord` with a specific partition key?
I've checked this...
1
answers
0
votes
976
views
asked 2 years agolg...