I have an Apache Beam streaming project that calculates data and writes it to the database, what is the best way to reprocess all historical records after a bug
I have multiple AWS kinesis data streams/firehose with structured data in CSV format. I need to perform analytics on that data with kinesis data analytics. But
Context: We use Kinesis analytics to process our sensor data and find anomalies in the sensor data. Goal: We need to identify the sensors that didn’t send