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.
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
126
views
asked 2 years agolg...
Changing the value of the integration mapping results in bad kinesis input.
1
answers
0
votes
516
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
906
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
1569
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
554
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
988
views
asked 2 years agolg...
Hi! I just deployed a solution to recover the abandoned calls from the queue and when no one answers the phone, however I'm not really sure how the billing works for this specific solution since I...
0
answers
0
votes
87
views
asked 2 years agolg...
Hi,
I'm using CDK to manage my infrastructure. I've setup an SES account that's now out of the Sandbox and would like to monitor sent emails on my account. I'm using CDK to manage my cloud...
0
answers
0
votes
105
views
asked 2 years agolg...
Hi, Im trying to update my current KCL 2.4 application to work with multiple streams using the MultiStreamTracker setup. The intial app was created using the tutorial as a base...
0
answers
1
votes
151
views
asked 2 years agolg...
How to create a kinesis firehose delivery stream with dynamic partitions enabled using python cdk?lg...
I am trying to create a firehose delivery stream with dynamic partitions enabled. Below is what I have got so far.
```
analytics_delivery_stream = kinesisfirehose.CfnDeliveryStream(
self,...
0
answers
0
votes
149
views
asked 2 years agolg...
I have a lambda function which receives logs from cloudwatch using a subscription filter and has to send them to firehose to be delivered to an s3 bucket.
The same lambda function receives two kinds...
1
answers
0
votes
541
views
asked 2 years agolg...
Hi, the current pipeline I am implementing involves a Kinesis Data Stream -> Kinesis Delivery Stream -> S3 route, however when setting the buffer intervals (Both s3 and transformation) to near 5...
2
answers
0
votes
546
views
asked 2 years agolg...