Skip to main content
Beam pipeline builder
Allium Beam lets you tap into any Allium Datastream, apply filters and JavaScript transforms, and deliver processed data to Kafka or SNS — without building infrastructure.
Source (any Allium Datastream) → Transforms (filter / transform) → Sinks (Kafka, SNS)

Key benefits

Filtered at the source

Receive only the events you need. Reduce processed events by 90%+ compared to full firehose streaming.

Deploy in 30 seconds

Visual pipeline builder with no Kafka consumers, transformation pipelines, or filtering logic to build.

Production-grade

SOC 1 & 2 certified. Same infrastructure powering Phantom, Uniswap, Circle, and MetaMask.

Use cases

Use caseData problemBeam solution
Wallet notificationsAlert users on stablecoin arrivals, token transfers, or NFT mints — without processing the full chain.Filter by wallet address set, receive decoded transfer events, trigger notifications directly.
Transaction monitoringTrack activity for specific contracts or protocols. Full firehose volume is unmanageable.Filter by contract address, receive decoded events, stream to your monitoring system.
Compliance alertingFlag transactions above a threshold or monitor sanctioned addresses.Filter by amount or address list, receive decoded data, trigger compliance workflows.
Real-time dashboardsPower live metrics without building data infrastructure.Stream filtered, decoded data to your database. Query directly.
DeFi protocol monitoringTrack liquidations, large swaps, or position changes across protocols.Filter by protocol events, receive decoded data with enriched context.

Beam vs Datastreams

Not sure which to use? Here’s a quick comparison.
DatastreamsBeam
What it isFull blockchain data streams delivered to your message brokerCustom-filtered stream transformations with a visual builder
Best forAnalytics pipelines, data lakes, teams with streaming infrastructureNotifications, monitoring, alerting — teams who want filtered streams
DataFull chain topics (e.g., ethereum.transactions)Custom-filtered + transformed events
LatencyP50 ~1-2 secondsP50 ~1-2 seconds
You handleFiltering, transformation, routingJust the business logic
Setup timeHours30 seconds
Beam is currently in beta. To get access, contact support@allium.so or your account team.

Next steps