// market data infrastructure

All Exchanges.
One Feed.
Zero GC.

Zig ZMQ No GC <1ms dispatch ZeroMQ SUB

Real-time orderbook and ticker data from 9+ major exchanges, normalized to a single contract and streamed via ZMQ. Catch cross-exchange and triangular arbitrage opportunities before everyone else. Built on Zig — no garbage collector, no jitter, no compromises.

Get Early Access View Stream Docs

Aggregating from

Binance KuCoin Bitfinex OKX Bybit Bitget Gate Coinbase Kraken + more

zmq-sub tcp://free_api.arbstream.net:5556

LIVE

time exchange type pair price

Simulated feed · forward latency <1ms

// what you get

Built for Arbitrage.
Designed for Profit.

Ultra-Fast Dedicated Streams

Two purpose-built ZMQ streams: orderbook depth on port 6001, ticker data on port 6002. No managing individual WebSocket feeds — subscribe to what you need, nothing more.

<1ms

dispatch

Unified Contract Format

All exchange data normalized to a single, consistent JSON schema. No more translating between API quirks — Binance, OKX, Kraken all speak the same language.

schema

Deep Orderbook Data

Full depth market data aggregated in real-time across all connected exchanges. Detect cross-exchange and triangular arbitrage — BTC→ETH→USDT and back — the moment a spread opens, not after it's gone.

Full

depth

Zero-GC Zig Runtime

The data pipeline runs on Zig — no garbage collector means no GC pauses, no jitter. Deterministic latency that garbage-collected runtimes simply cannot match.

GC pauses

Simple Access Model

Start free with 2 exchanges — no credit card, no setup time. Upgrade to full access for all major exchanges at a flat monthly rate.

to start

// integration

Simple, Powerful Streams

Two dedicated ZMQ streams. Orderbook data on port 6001, ticker data on port 6002. Works with any language.

          example.js
          zeromq v6+
        

const zmq = require("zeromq");
const sock = new zmq.Dealer();
sock.routingId = "client-1:DLEflKfiKZdZxGKa";

async function run() {
  sock.connect("tcp://free_api.arbstream.net:6001"); // orderbook stream
  await sock.send(""); // register with the server

  for await (const [msg] of sock) {
    try {
      console.log(JSON.parse(msg.toString()));
    } catch (err) {
      console.log("failed parsing json: ", err);
      process.exit(1);
    }
  }
}

run();

          example.py
          pyzmq
        

import zmq

ctx  = zmq.Context()
sock = ctx.socket(zmq.DEALER)
sock.setsockopt(zmq.ROUTING_ID, b"client-1:DLEflKfiKZdZxGKa")
sock.connect("tcp://free_api.arbstream.net:6001") # orderbook stream; ticker on 6002
sock.send(b"") # register with the server

while True:
    print(sock.recv_string())

          example.go
          github.com/zeromq/goczmq
        

// brew install zeromq czmq libsodium pkg-config
// go get gopkg.in/zeromq/goczmq.v4
package main

import (
    "fmt"
    "log"
    "github.com/zeromq/goczmq"
)

func main() {
    dealer := goczmq.NewSock(goczmq.Dealer)
    defer dealer.Destroy()
    dealer.SetIdentity("client-1:DLEflKfiKZdZxGKa")

    // orderbook stream; ticker stream available on port 6002
    if err := dealer.Connect("tcp://free_api.arbstream.net:6001"); err != nil {
        log.Fatal(err)
    }
    dealer.SendFrame([]byte{}, goczmq.FlagNone) // register with the server

    for {
        msg, _, err := dealer.RecvFrame()
        if err != nil {
            log.Fatal(err)
        }
        fmt.Println(string(msg))
    }
}

          src/main.zig
          github.com/uyha/zimq
        

// build.zig.zon: zig fetch --save git+https://github.com/uyha/zimq.git
const std = @import("std");
const zimq = @import("zimq");

pub fn main() !void {
    var ctx = try zimq.Context.init();
    defer ctx.deinit();

    // create DEALER socket
    var dealer = try zimq.Socket.init(ctx, .dealer);
    defer dealer.deinit();

    // set routing ID before connecting
    try dealer.set(.routing_id, "client-1:DLEflKfiKZdZxGKa");
    // orderbook stream; ticker stream available on port 6002
    try dealer.connect("tcp://free_api.arbstream.net:6001");
    try dealer.sendSlice("", .{}); // register with the server

    while (true) {
        var msg = zimq.Message.empty();
        defer msg.deinit();
        _ = try dealer.recvMsg(&msg, .{});

        std.log.info("{s}\n", .{msg.slice()});
    }
}

Orderbook Message

{
  "src":  "kucoin",
  "type": "orderbook",
  "pair": "ETH:USDT",
  "ts":   1771228848200,
  "bids": [["3421.5","1.234"], ...],
  "asks": [["3421.6","2.567"], ...]
}

Ticker Message

{
  "src":          "kucoin",
  "type":         "ticker",
  "pair":         "ETH:USDT",
  "ts":           1771228848200,
  "lastPrice":    3421.5,
  "highPrice24h": 3550.2,
  "lowPrice24h":  3398.1,
  "price24hPcnt": 0.015,
  "volume24h":    45821.34
}

All data normalized to a consistent JSON schema across all exchanges.

// pricing

Simple, Transparent Pricing

Start free. Upgrade when you need the full picture.

Free

$0 /month

✓ KuCoin & Gate exchanges
✓ Orderbook & ticker data
✓ Most popular trading pairs
✓ Community support

Try Free Stream

Early Bird

Professional

$49 /month

Locked in forever at early bird pricing

✓ All 9+ major exchanges
✓ Unified orderbook & ticker stream
✓ Unlimited trading pairs
✓ Priority support

Get Started

Enterprise

Custom

✓ Everything in Pro
✓ Dedicated infrastructure
✓ 99.9% uptime SLA
✓ 24/7 dedicated support

Contact Sales

All Exchanges.
One Feed.
Zero GC.

Built for Arbitrage.
Designed for Profit.

Ultra-Fast Dedicated Streams

Unified Contract Format

Deep Orderbook Data

Zero-GC Zig Runtime

Simple Access Model

How It Works

Connect

Trade

Simple, Powerful Streams

Simple, Transparent Pricing

Start Receiving
Live Market Data
Today.

All Exchanges. One Feed. Zero GC.

Built for Arbitrage. Designed for Profit.

Ultra-Fast Dedicated Streams

Unified Contract Format

Deep Orderbook Data

Zero-GC Zig Runtime

Simple Access Model

How It Works

Connect

Trade

Simple, Powerful Streams

Simple, Transparent Pricing

Start Receiving Live Market Data Today.

All Exchanges.
One Feed.
Zero GC.

Built for Arbitrage.
Designed for Profit.

Start Receiving
Live Market Data
Today.