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.
In a Glue streaming job, is it possible read from Multiple Kinesis sources in my spark script?
something like:
```
streams = ["streamA", "streamB"]
for stream in streams:
...
3
answers
0
votes
652
views
asked 5 months agolg...
I want to store the schema for Avro formatted messages in Glue schema registry, and I want to use this schema when reading records from Kinesis data stream.
Currently, for reading records from the...
1
answers
0
votes
682
views
asked 5 months agolg...
DMS CDC Replication Task from RDS MariaDb is not failing but records are not appearing in Kinesislg...
I'm trying to CDC data from RDS MariaDb to a Kinesis Stream.
The DMS Replication Task itself is successful. I also see no errors in the logs. However, no records actually arrive at the Kinesis...
0
answers
0
votes
521
views
asked 5 months agolg...
I am having issues streaming video with Kinesis video streams producer sdk c++ from raspberry pi 4. I followed [AWS Official...
0
answers
0
votes
2577
views
asked 6 months agolg...
I want to access cross account kinesis consumer using dotnet. I didn't find the implementation of the necessary library SubscribeToShard in dotnet. Cn you help me with necessary information how it can...
1
answers
0
votes
404
views
asked 6 months agolg...
I am running an AWS Glue Job, and the job is doing what it should, it takes the records from Kinesis stream and is putting it into the data lake. But it ends with a failure and error is as given...
2
answers
0
votes
292
views
asked 6 months agolg...
Hi folks,
I have added the resource-based policies to AWS kinesis stream. Once after adding that policy How it will work?
I have assumed some working scenario for the below following cases for the...
0
answers
0
votes
58
views
asked 6 months agolg...
I'm currently designing an IoT system on AWS to manage a substantial daily message volume of around 25 million. The services I intend to use involves:
1. **AWS IoT Core**: Ingesting data from IoT...
2
answers
0
votes
262
views
asked 6 months agolg...
Don't see any data when Migrating existing and changes data from MYSQL to S3 using DMS and Kinesis.lg...
I am using DMS and Kinesis DataStream and Delivery stream to migrate existing and changes from MYSQL to S3 bucket. But I don't see the data is coming in S3. I specified the schema name and table name...
0
answers
0
votes
182
views
asked 6 months agolg...
Traceback (most recent call last):
File "data.py", line 88, in <module>
generate(STREAM_NAME, boto3.client('kinesis',region_name='us-east-2'))
File "data.py", line 83, in generate
...
0
answers
0
votes
78
views
asked 6 months agolg...
pipeLine : In order to index data to opensearch, kinesis is called from lambda and the data is forwarded to opensearch.
when sending demo data to 'Opensearch' from 'kdf', 'Opensearch' set index...
1
answers
0
votes
598
views
asked 7 months agolg...
Hello,
Does anyone know the reason why I got this error when calling the UpdateEventSourceMapping operation? Im using this operation in a function that can disable a kinesis trigger when there's a...
1
answers
0
votes
280
views
asked 7 months agolg...