Transaction Stream gRPC

The Transaction Stream API is a gRPC API for streaming historical and real-time transaction data into indexing processors (Aptos API documentation). It is the right feed for backfills, event processors, and read-model builders.

transaction stream -> decoder -> idempotent processor -> checkpoint store -> database

Processors should store the last committed version/checkpoint only after their database transaction commits. On restart, resume from the stored cursor and tolerate duplicate delivery.