Kafka Streams for real-time blockchain data
Bitquery's Kafka channel pushes decoded on-chain data — DEX trades, transfers, new tokens, balances — straight onto durable topics across 40+ chains. Guaranteed delivery, offset replay and Protobuf or JSON, so your pipeline never drops a message and backfills itself on reconnect. No nodes, no Geyser, no Kafka pipeline to build.
Kafka leads when you need every message, in order.
Kafka is the durable lane — partitioned topics, offset replay and guaranteed delivery in Protobuf or JSON. Reach for gRPC, WebSocket or GraphQL when raw speed, the browser or history matters more than durability.
Durable topics with offset replay — never miss a message, backfill on reconnect. Protobuf or JSON, partitioned per chain across 40+ networks.
Binary Protobuf firehose for Solana — the lowest-latency lane when raw speed beats durability.
Browser-ready GraphQL subscriptions — subscribe to exactly the events you filter.
The same schema for historical reads — backtest and hydrate from genesis.
One Kafka cluster, every kind of on-chain event.
Subscribe to the topics you need — decoded, partitioned per chain and replayable by offset. The same topic shape spans Ethereum, Solana, BSC, Base, Tron and 40+ more networks.
Forget building your own Kafka pipeline off nodes.
Running Kafka off your own archive nodes means a decoder per chain, a connector per topic and a team to keep partitions, replication and replay healthy. Bitquery hands you decoded events on managed topics.
What teams ship on Kafka Streams.
Every one is a consumer on the same durable topics — subscribe, replay by offset and never miss a message.
Durable ingestion to your warehouse
Consume DEX trades and transfers into Snowflake, BigQuery or ClickHouse with offset replay — backfill cleanly after any outage, never drop a row.
Read the docs →Real-time analytics
Pipe the multi-chain firehose into live dashboards and on-chain analytics that stay accurate because every message is delivered and ordered per partition.
Read the docs →Alerting on on-chain events
Filter the trades, transfers and new-token topics to fire alerts the instant a whale moves, a pool drains or a token launches — across every chain at once.
Read the docs →What teams say about our data
"We did a thorough search of the market for the best onchain data. Bitquery came out on top — and now powers all live prices across Nansen. We don't think of them as a vendor. They're a partner."
Bitquery does the hard work of parsing blockchain transaction data into a usable form so that we don't have to. We use their interface to diagnose issues with complex transactions and their analytics as a starting point for our own.
They proved they had the technology to deliver sophisticated data solutions. We extended our support through the Binance X fellowship — building an open-source library of visualization widgets on their blockchain data.
The complex raw data is available at different levels of detail and from different viewpoints — whether we need simple aggregated transfers or parameters for failed contract calls. The support is responsive, friendly and quick.
Partnering with Bitquery has been highly cost-effective — leveraging their established infrastructure rather than building our own let us rapidly expand our blockchain support and reach a much broader segment of on-chain users.
Bitquery's products are very intuitive and easy to use. We currently use their products to obtain DEX-related trading and liquidity information, which saves us the manpower and tedious technical details required to develop our own system. Their excellent technical team deserves special praise; they provide near-24/7 support and resolve issues quickly. I greatly appreciate their products and work ethic.
Bitquery provides the infrastructure we rely on every day. Fast, reliable, and comprehensive across the chains that matter to our business.
Start free. Scale when you ship.
Query every blockchain on every plan — no chain is paywalled. Move to commercial when you need volume, SLAs and bulk datashares.
- All blockchains, all plans
- 10 requests / minute
- 2 streams for testing
- GraphQL IDE access
- Scalable calls, no throttling
- SQL, Cloud, Kafka & more
- 24/7 engineering access
- Dedicated onboarding & SLA
- Snowflake, BigQuery, S3, Azure
- No setup or infrastructure
- Structured for AI agents & MCP
- Audit data for custodians
Kafka streaming, answered.
What are Bitquery Kafka Streams?
What does guaranteed delivery and offset replay mean?
Protobuf or JSON?
Which chains and topics are covered?
How is this different from running my own Kafka off nodes?
How do I get started?
Stream blockchain data over Kafka.
Free API key, decoded topics across 40+ chains, guaranteed delivery with offset replay. Connect a consumer and never miss a message.