Scalable Go Service for Canonical Ethereum Block Streaming and Event Pipelines

Hey everyone!

I’ve been working on an open-source project called blockscan-ethereum-service, written in Go:
https://github.com/pancudaniel7/blockscan-ethereum-service

What it does

It’s a production-grade microservice that ingests Ethereum blocks in real time and streams them into Kafka as canonical block events. It’s built with performance, reliability, and horizontal scalability in mind, making it a strong fit for backend systems that depend on on-chain data.

Why it matters

Many existing block scanners are heavy, highly opinionated, or not designed for real-world backend architectures. This service focuses on:

• Real-time block ingestion via WebSocket subscriptions
• Partition-aware Kafka publishing with effectively-once delivery semantics
• Reorg awareness, emitting tombstone and update events on chain reorganizations
• Durable coordination using Redis markers
• Observability with structured logs, metrics, and traces

Who might find it useful

• Go developers building Web3 backends
• Teams designing custom Ethereum data pipelines
• Anyone integrating blockchain data into event-driven systems

If you check it out and find it useful, I’d truly appreciate a star on the repo.
Happy to answer questions or discuss the design and architecture!