Returns Protobuf schemas for the data streamed and stored in S3 for a given topic
npm install bitquery-protobuf-schemabitquery-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.
---
* 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
---
Install with npm:
``sh`
npm i bitquery-protobuf-schema
---
Here's how to load a Protobuf schema for any Bitquery Kafka stream topic:
`js
const { loadProto } = require('bitquery-protobuf-schema');
let ParsedIdlBlockMessage;
let topic = '
ParsedIdlBlockMessage = await loadProto(topic);
`
Once loaded, use the parsed schema to decode incoming Protobuf messages from the Kafka stream:
`js`
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.
---
To start streaming real-time blockchain data using Protobuf + Kafka, contact:
📧 sales@bitquery.io
---
Explore Bitquery’s on-chain data streaming docs:
* Solana Shreds Stream (High-performance Solana data)
* Trading Bot Tutorial (Kafka Sniper Bot)
---
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.