Real-time blockchain data streaming for engineering teams
Stream blockchain events to your systems in real-time. Get full chain data or filtered streams — without building infrastructure.
Get live onchain data — without the custom infrastructure
Stream from 150+ blockchains
Access EVMs, Solana, Hyperliquid, and more — new chains ingested in <1 week on average.
Reduce processed events by 90%+
Filter at source with Beam — receive only the events you need, not the full firehose.
Deploy in 30 seconds, not months
Visual pipeline builder or AI Beam Builder — no Kafka consumers to build, no transformation pipelines to maintain.
%201.png)
Real-time, production-ready streams for every use case.
Push-based data streams for wallets, tokens, and trades.
.avif)
Choose raw logs or enriched schemas
Stream raw blockchain logs or pre-enriched data — balances, DEX trades, NFT events, token transfers at your preferred level of processing.
Filter down to what matters
Subscribe by chain, schema, or entity to stream only the events you need.
Deliver to your stack
Push data to Kafka, Pub/Sub, or SNS. Websockets also available.
.avif)
Trust production-grade accuracy
Rely on automatic reorg handling and consistency checks — we reconcile chain reorganizations so you don't have to.
.avif)
Replay historical events on demand
Access historical messages when needed — retention policies ensure you never lose critical events.
Allium is your system of record
Beam is the real-time datastreaming offering within Allium’s broader data platform. Unlike point solutions, the same data powering your streaming also powers your analytics, compliance, and product teams.
What You Get
Real-time streaming
Historical analytics
Data warehouse delivery
Decoded schemas
Attribution data
SOC certification
Allium reduces the cost of full firehose streaming
Challenge
Data volume
Infrastructure
Engineering time
Maintenance
ROI at a glance
Metric | Value |
|---|---|
Processed events reduction | 90%+ (filter at source vs full firehose) |
Engineering time saved | 3-6 months vs 30-second deployment |
Downstream infra eliminated | Kafka consumers, transformation jobs, filtering logic |
Get streams that fit your data infrastructure
What it is
Best for
Data
ethereum.transactions, solana.dex_trades)Latency
You handle
Sinks
Setup time
Engineering effort
Datastreams
Subscribe to full chain topics and process events in your infrastructure.
- Choose topics —
ethereum.transactions,solana.dex_trades, etc. - Connect your Kafka or Pub/Sub — Events flow automatically
- Build your processing — Filter, transform, route to your systems
Beam
Build custom-filtered stream transformations — define filters and transforms in a UI, receive only what you need.
Define your filters — Contract addresses, wallet set lookups (100K+ addresses), value thresholds
Add transformations — Reshape data, extract fields, enrich events
Choose your sink — Kafka, SNS, Pub/Sub, direct DB
Deploy in 30 seconds — Visual builder or AI Beam Builder
Best for: Notifications, monitoring, alerting — custom-filtered streams without building infrastructure
Why teams choose Allium over webhooks and subgraphs
Webhooks
Best-effort delivery means messages are lost during outages or system downtime.
Teams end up building complex retry logic and backup systems to handle inevitable failures.
Subgraphs
Raw blockchain events require specialized knowledge to decode and query.
GraphQL adds complexity and learning curve.
Indexing costs scale exponentially with query volume, making production usage expensive.
Teams need blockchain expertise to maintain and troubleshoot.
Guaranteed delivery with enterprise message brokers (Kafka, Pub/Sub, SNS)
Decoded & enriched data with consistent schemas
Standard SQL without graph expertise
Predictable scaling costs for production workloads
Broader data platform — streaming, analytics, compliance from one source
Compare Allium
Engineered for production reliability
150+
Supported chains
1-3s
Data freshness (P50)
99.9%
Uptime
24/7
SLA
Supported Integrations
Kafka
Apache Kafka Integration
Pub/Sub
Google Cloud Pub/Sub Integration
SNS
Amazon SNS Integration
ClickHouse
Direct database writes (Beam)
Postgres
Direct database writes (Beam)
Websockets
Get APIs or datastreams over websockets
Powering high performance real-time applications
Phantom uses Allium Developer APIs to power wallet balances and transaction histories for millions of users. During Jupiter's 2024 airdrop, Allium handled 90,000 requests per second with zero downtime.
Magic Eden relies on Allium to filter inorganic marketplace activity and power real-time transaction data in their wallet — ensuring accurate market intelligence and user insights.
Built on Allium's dedicated Hyperliquid node, our realtime Hyperliquid dashboard surfaces trades, validator activity, and protocol metrics as they happen onchain.
MetaMask uses Allium APIs to power real—time balance calculations and transaction data across their wallet infrastructure.
Explore use cases
Payment Processing
Monitor deposits and withdrawals in real-time to credit accounts and trigger workflows instantly.
Risk & Fraud Detection
Stream transactions to fraud detection systems for real—time pattern analysis and alerting.
Portfolio Tracking
Update portfolio positions as trades execute across DEXs and protocols.
Treasury Operations
Track treasury movements and automate rebalancing workflows with sub-second event notifications.
FAQ
Should I use Datastreams or Beam?
Use Datastreams if you have streaming infrastructure and want full chain data with maximum control. Use Beam if you want custom-filtered stream transformations without building or maintaining real-time infrastructure — ideal for notifications, monitoring, and alerting.
Can I use both?
Yes. Some teams use Datastreams for analytics (full data to data lake) and Beam for user-facing features (custom-filtered streams for notifications).
What’s the latency difference?
Datastreams delivers at P50 ~5 seconds. Beam delivers at P50 <2 seconds. Beam is faster because filtering and transformation happen at source through co-located processing.
How much infrastructure does Beam eliminate?
Beam eliminates downstream Kafka consumers, transformation pipelines, and filtering logic.
How much engineering time does Beam save?
Building custom streaming pipelines typically takes 3-6 months. Beam deploys in 30 seconds with a visual builder or AI Beam Builder.
Does Beam support my sink?
Beam supports Kafka, AWS SNS, Google Pub/Sub, and direct database sinks (ClickHouse, Postgres).
What kind of filters and transformations does Beam support?
Filters: contract address filtering, large wallet set lookups (100K+ addresses), value thresholds, event type selection. Transformations: data reshaping, field extraction, event enrichment — all defined in the UI.
Why Allium over Goldsky?
Goldsky Mirror is streaming-only. Allium gives you streaming plus Explorer, Datashares, APIs, and attribution data — all from the same standardized schemas. When multiple teams reference the same Allium data, switching creates coordination cost across finance, product, engineering, and compliance.
Explore more products
Allium Explorer
Write SQL queries. Build charts.
Allium Datashares
Join onchain data with your internal databases and tools
Custom Dashboards
Get custom analytics solutions tailored to your use case
Allium AI
Write queries faster
Allium Developer
Real-time APIs
Real-Time Streaming
Live event data
Allium Terminal
Analyze onchain activity by geography, entity type, and economic relationship.