Real-Time Blockchain Data Streaming with Kafka

Behind our Notifications feature, we built a high-throughput data streaming infrastructure powered by Apache Kafka. We are now making these streams available to teams and businesses that need real-time blockchain data delivered directly to their systems.

Available Data Streams

Our Kafka infrastructure produces three core data streams, updated every 10 minutes across Ethereum, Solana, and Base:

• Holder Count Stream - Token holder counts segmented by position size (all holders, holders with $10+, $50+, $100+, $250+, $500+, $1K+, $10K+, $100K+, $1M+ in value)
• Price and Market Cap Stream - Current USD price and market cap for tracked tokens
• Wallet Balance Stream - Individual wallet balance changes with old and new amounts, enabling whale tracking and flow analysis

Here is an example of a holder count stream message:

{
  "token_ca" "CzLSujWBLFsSjncfkh59rUFqvafWcY5tzedWJSuypump",
  "network" "SOL",
  "updated_at" 1740300600,
  "holders" 58412,
  "holders_10usd" 22847,
  "holders_50usd" 10523,
  "holders_100usd" 6891,
  "holders_250usd" 3204,
  "holders_500usd" 1876,
  "holders_1000usd" 943,
  "holders_10000usd" 187,
  "holders_100k_usd" 24,
  "holders_1m_usd" 3
}

{
  "token_ca" "CzLSujWBLFsSjncfkh59rUFqvafWcY5tzedWJSuypump",
  "network" "SOL",
  "updated_at" 1740300600,
  "price_usd" 0.00234,
  "market_cap" 2340000
}

{
  "token_ca" "CzLSujWBLFsSjncfkh59rUFqvafWcY5tzedWJSuypump",
  "network" "SOL",
  "wallet_address" "7xKXtg2CW87d97TXJSDpbD5jBkheTqA83TZRuJosgAsU",
  "old_amount" "150000000",
  "new_amount" "982000000",
  "updated_at" "1740300600"
}

Use Cases

Teams are already using blockchain data streams like these for a range of applications:

Trading and Portfolio Dashboards

Feed holder and price data directly into your trading dashboard or portfolio tracker. Detect early signals like accumulation by large holders or sudden holder count drops before price reacts.

Whale Watching and Smart Money Tracking

The wallet balance stream lets you monitor large wallet movements in near real-time. Build alerts for whale buys and sells, track smart money flows, or flag wallets that consistently enter positions early.

Get updates about whale movements

On-Chain Analytics Platforms

Power your analytics product with structured, reliable holder data. Our streams provide granular holder distribution data segmented by position size, something most data providers do not offer.

DeFi Protocol Monitoring

Monitor token holder distribution to assess decentralization, track governance token concentration, or trigger protocol actions based on holder thresholds.

Research and Backtesting

Consume the streams into your data warehouse to build historical datasets for backtesting strategies based on holder behavior and distribution patterns.

How It Works

Data flows from our indexing infrastructure into Kafka topics with 3 partitions and 7-day retention. You connect as a Kafka consumer using SASL authentication, giving you a standard, battle-tested integration path. Messages are JSON-encoded and follow a stable schema.

Each stream updates every 10 minutes. The holder count stream includes position-size breakdowns, the price stream delivers USD-denominated pricing and market cap, and the wallet balance stream provides per-wallet deltas with exact amounts.

Tokens parsed per second across holder, price, and balance streams

Consumer lag stays low, ensuring near real-time delivery

Custom Solutions

We are currently offering data streaming as a custom solution. Whether you need a single stream or the full set, we can tailor access to your requirements. This includes custom filtering by network, token, or market cap range.

If you are building a product that needs reliable, real-time blockchain holder data, reach out to us at [email protected] and we will put together a solution that fits your needs.