bitquery-protobuf-schema

bitquery-protobuf-schema is an NPM package by Bitquery, designed to simplify working with on-chain data streaming pipelines powered by Protobuf and Kafka. This package automatically returns Protocol Buffer (.proto) schemas for Bitquery’s Protobuf Kafka streams when you provide the stream's topic name.

Bitquery is a leading on-chain data provider, offering blockchain intelligence via GraphQL APIs, WebSocket streaming, and high-performance Kafka streams. This package removes the hassle of repeatedly downloading .proto files manually and allows developers to integrate directly with Bitquery’s real-time blockchain data streams.

🚀 Features

• Easy loading of Protobuf schemas for Bitquery Kafka stream topics
• Ideal for applications using real-time streaming on-chain data
• Automatically decodes blockchain events, transactions, logs, shreds, and more
• Useful for building analytics dashboards, trading bots, monitoring tools, and ingestion pipelines
• Zero need to manually store or update .proto files

📦 Installation

Install with npm:

npm i bitquery-protobuf-schema

🧠 Usage

Here's how to load a Protobuf schema for any Bitquery Kafka stream topic:

const { loadProto } = require('bitquery-protobuf-schema');

let ParsedIdlBlockMessage;
let topic = '<topic>';

ParsedIdlBlockMessage = await loadProto(topic);

Once loaded, use the parsed schema to decode incoming Protobuf messages from the Kafka stream:

const buffer = message.value;
const decoded = ParsedIdlBlockMessage.decode(buffer);

This gives you fully structured on-chain data decoded directly from Bitquery's Protobuf streaming infrastructure.

📡 Access Bitquery Protobuf Kafka Streams

To start streaming real-time blockchain data using Protobuf + Kafka, contact: 📧 [email protected]

📚 Documentation

Explore Bitquery’s on-chain data streaming docs:

• Kafka Streaming Concepts

• Bitcoin Protobuf Streams

• EVM Protobuf Streams

• Solana Shreds Stream (High-performance Solana data)

• Tron Protobuf Stream

• Trading Bot Tutorial (Kafka Sniper Bot)

🏁 Summary

bitquery-protobuf-schema helps developers decode streaming, real-time on-chain data from Bitquery’s Kafka Protobuf infrastructure without managing .proto files manually. Whether you're building blockchain analytics, DeFi trading bots, monitoring systems, or ingestion pipelines, this package streamlines your integration with Bitquery’s high-performance data streams.