Questions about amazon-kinesis
Read more about amazon-kinesis
python (12.9k questions)
javascript (9.2k questions)
reactjs (4.7k questions)
java (4.2k questions)
java (4.2k questions)
c# (3.5k questions)
c# (3.5k questions)
html (3.3k questions)
Pyflink session window aggregation by separate keys
I'm trying to wrap my head around the pyflink datastream api.
My use case is the following:
The source is a kinesis datastream consisting of the following:
cookie
cluster
dim0
dim1
dim2
time_event...
irr_pie
Votes: 0
Answers: 0
Apache Flink : Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Could not serialize inputs
I have a Flink-1.13 program that reads data from a Kinesis stream containing records with different schemas.
My program iterates over all the possible schemas contained into the stream, filters a main...
nach0
Votes: 0
Answers: 0
spring-cloud-stream-binder-kinesis with AWS Glue schema registry
How to configure spring-cloud-stream-binder-kinesis with AWS Glue schema registry for Avro schema. I didn't find any options in the documentation of binder-kinesis or spring-integration-aws. There is ...
Ravi Subbarao
Votes: 0
Answers: 0
Decrypting file stored in AWS S3 by Kinesis firehose
I'm using Kinesis firehose to stream log data from Cloudwatch to AWS S3. The files are encrypted by kinesis data delivery stream with sse kms then stored in S3. However files are greater than 4kb, so ...
opseator
Votes: 0
Answers: 0