Reliable, Fast Access to On-Chain Data Insights | Confluent

This post details TokenAnalyst's implementation of a 'block confirmer' using Kafka Streams to handle blockchain reorganizations. It describes maintaining a fork tree in a Kafka Streams state store to process incoming blocks and propagate them only after a confirmation threshold is met, ensuring effective once semantics by discarding already registered and confirmed blocks. It also highlights the use of Kafka Streams' fault tolerance for rolling deploys and zero-downtime environments.