A collection of high-performance blockchain data ingestion services (producers) that fetch data from diversas sources and publish it to Kafka using shared Protocol Buffer definitions.
| Directory | Language | Source | Target Chain(s) |
|---|---|---|---|
eth-go-producers |
Go | JSON-RPC | Ethereum |
evm-producers |
TypeScript | JSON-RPC | EVM-Compatible (Base, HyperEVM, etc.) |
hyperliquid-producers |
TypeScript | WebSocket | Hyperliquid L1 |
solana-producers |
TypeScript | gRPC (Yellowstone) | Solana |
Each service in this workspace is responsible for:
- Connecting to a specific blockchain data source (RPC, WebSocket, or gRPC).
- Mapping raw blockchain data to shared Protobuf structures.
- Publishing the structured data to Kafka topics for downstream consumption.
Producers rely on the following shared packages (located in sibling repositories or managed via workspace links):
@ethereum-kafka-indexer/protos: Common Protocol Buffer definitions.@ethereum-kafka-indexer/shared: Shared configuration and utility logic.