Skip to content

Commit 83eaa3b

Browse files
Merge pull request #161 from Divyn/main
Adding topics to kafka page
2 parents 1d92a4a + bf5e490 commit 83eaa3b

File tree

1 file changed

+37
-22
lines changed

1 file changed

+37
-22
lines changed

docs/streams/kafka-streaming-concepts.md

Lines changed: 37 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -125,13 +125,6 @@ sasl_conf = {
125125
### Subscribe to particular topic(s)
126126

127127
To receive messages you first create consumer and subscribe it to a topic or list of topics.
128-
Topic contains messages of the same type, for example:
129-
130-
- tron.transactions contains messages with transactions, smart contract calls and events in Tron blockchain
131-
- tron.broadcasted.transactions contains messages from mempool broadcasted channel ( before they included in blocks )
132-
- tron.dextrades contains trades happen on Tron blockchain
133-
- solana.dextrades contains trades happen on Solana blockchain
134-
- and so on...
135128

136129
General pattern of the topic name is:
137130

@@ -149,13 +142,9 @@ Our multi-chain [Price Index Streams](https://docs.bitquery.io/docs/trading/pric
149142
MESSAGE_TYPE is specific on blockchain, most blockchain has topics for:
150143

151144
- dextrades - events from DEX trading
152-
- dexorders - events on creation / changing status of DEX orders
153-
- dexpools - events on creation / changing status of DEX pools
154145
- transactions - events, calls, transactions
155-
- transfers - token and coin transfers events
156-
- instructions - details on instructions and associated accounts, transaction details
146+
- tokens - token and coin transfers events
157147
- raw - blocks or transactions directly from node
158-
- instruction_balance_updates - instruction-level information on balance updates for accounts and token supply updates ( for solana )
159148

160149
Refer to [Bitquery Streaming Protobuf](https://github.com/bitquery/streaming_protobuf) schemas for structure.
161150

@@ -166,14 +155,47 @@ Refer to [Bitquery Streaming Protobuf](https://github.com/bitquery/streaming_pro
166155
- `*.broadcasted.transactions.proto``ParsedAbiBlockMessage`
167156
- `*.broadcasted.tokens.proto``TokenBlockMessage`
168157
- `*.broadcasted.dextrades.proto``DexBlockMessage`
169-
- `*.broadcasted.raw.proto``BlockMessage` ( Not yet deployed)
158+
- `*.broadcasted.raw.proto``BlockMessage`
170159

171160
**Committed Blocks:**
172161

173162
- `*.transactions.proto`
174163
- `*.tokens.proto`
175164
- `*.dextrades.proto`
176-
- `*.raw.proto` (Coming soon)
165+
- `*.raw.proto`
166+
167+
## Complete List of Topics
168+
169+
All the topics send data in the **protobuf** format
170+
171+
### EVM chains
172+
173+
(For mempool data, add .broadcasted after chain name)
174+
175+
- eth.transactions.proto
176+
- eth.tokens.proto
177+
- eth.dextrades.proto
178+
- bsc.transactions.proto
179+
- bsc.tokens.proto
180+
- bsc.dextrades.proto
181+
- base.transactions.proto
182+
- base.tokens.proto
183+
- base.dextrades.proto
184+
- matic.transactions.proto
185+
- matic.tokens.proto
186+
- matic.dextrades.proto
187+
- optimism.transactions.proto
188+
- optimism.tokens.proto
189+
- optimism.dextrades.proto
190+
191+
### Other Chains
192+
193+
- tron.transactions.proto
194+
- tron.tokens.proto
195+
- tron.dextrades.proto
196+
- solana.transactions.proto
197+
- solana.tokens.proto
198+
- solana.dextrades.proto
177199

178200
Contact our support team for the topics that you can connect to for your specific needs.
179201

@@ -196,7 +218,7 @@ Typicaly you need setup of one consumer per one topic, as the message parsing fo
196218

197219
> Note: For Price of a Token in DEXTrades topic, you need to calculate it using the amounts.
198220
199-
### Read and parse messages
221+
## Read and parse messages
200222

201223
Your consumer will read messages from the topic, and you will be able to parse them.
202224

@@ -206,13 +228,6 @@ Your consumer will read messages from the topic, and you will be able to parse t
206228
- Message contains the list of objects on the top level. Structure of objects corresponds to the topic that you consume.
207229
General schema is described in https://github.com/bitquery/streaming_protobuf.
208230

209-
## Protobuf Streams
210-
211-
We also provide streams in the proto format, currently there are three topics that are available on Solana;
212-
213-
- **solana.dextrades.proto**
214-
- **solana.tokens.proto**
215-
- **solana.transactions.proto** ( this includes unconfirmed transactions as well )
216231

217232
### What to Know About Protobuf Streams?
218233

0 commit comments

Comments
 (0)