📄️ Bitquery Kafka Streams - Understanding Concepts
Bitquery provides realtime data via Kafka as well in addition to GraphQL subscriptions. In this section, we'll see how Kafka-based streaming works and how to integrate it into your application using practical code examples. For price data streams, check out our Crypto Price API Kafka topic.
🗃️ L1/L2 Chains - Protobuf Data Streams
4 items
📄️ Go Example to Use Kafka Protobuf Streams for Real-time Data
This guide walks through the implementation of a Kafka consumer in Go to subscribe to a Kafka topic and process onchain data streams from Bitquery in real-time. The consumer connects to the Kafka brokers securely using SSL and handles incoming messages in Protobuf format.
📄️ Python Tutorial to use Solana Shreds from Kafka
This tutorial explains how to consume Solana transaction messages in protobuf format from Kafka using Python, and print them efficiently with decoded bytes fields in base58 format.
📄️ Javascript Tutorial to Setup Solana Kafka Shred Stream
This tutorial explains how to consume Solana transaction messages in protobuf format from Kafka using Javascript (Common JS), and print them efficiently with decoded bytes fields in base58 format.
📄️ Filtering Kafka Streams for Specific Usecases
In this section, we will see code examples and patterns for filtering Kafka stream messages based on specific criteria — such as smart contract methods, token addresses, DEX interactions, and more.
📄️ The Need for Real-Time Data on Solana: Latency, Scale, and Fidelity at Stake
“Better be first 99 percent of the time than second 100 percent of the time.”
📄️ Real-Time Blockchain Indexer: Build Reliable Indexers with Kafka Streams Instead of Archive Nodes, gRPC, or Webhook Services
Building a real-time blockchain indexer is one of the most challenging infrastructure tasks in the process of tracking trades, monitoring token transfers, parsing internal calls, or building a comprehensive on-chain analytics platform. If you decide to run your own archive node, you need to plan for big SSD storage (multiple TBs), fast disks / high IOPS, and robust backup/monitoring. If not, you might be looking for need reliable, low-latency access to blockchain data at scale.
📄️ Building a Trading Bot Using Bitquery Kafka Streams
This is a tutorial to build a fast, automated BSC (Binance Smart Chain) sniper bot for trading newly launched Four Meme tokens. The bot detects new token launches in real time via Bitquery’s Kafka streams, buys them instantly using the Four Meme Launchpad contract, and sells them after 1 minute—aiming to capitalize on rapid price movements.