Stream processing frameworks are used in many Internet of Vehicles projects. When the producer pushes messages to the proxy server, due to data throughput problems, the server may be down, and the system needs to be restarted to restore to the state before the downtime. However, some data may be lost at this time. In response to this problem, key task hot backups can be used to help record the read and write status, which can better ensure data consistency, and improve system fault tolerance.