Rivian vehicles stream over 5500 signals every 5 seconds, but only about 80 are relevant for push notifications. Without filtering, downstream jobs were overwhelmed by the full firehose. Mega Filter, a Flink application backed by RocksDB state and a Kafka metadata topic, trims traffic by 98 percent, from 172 TB a day to 3 TB. This talk explains how Mega Filter reduces load across Kafka, Flink, and EKS, how new or deprecated signals are handled in real time via DynamoDB and REST APIs, and the impact at scale for more than 100,000 cars.

