跳轉到主要內容
ChainStream 為 Tron 釋出的 Kafka topic 權威列表。所有 topic 使用 tron. 字首。 端到端的連線細節、SASL 憑證與 SDK 示例見 接入方式 → Kafka Streams → Tron Streams。權威的 Protobuf 定義見 github.com/chainstream-io/streaming_protobuf/tron。

​
分割槽

  • 代幣地址（TRC-20 合約地址的 base58 編碼）—— 用於代幣中心的 topic（tokens、dex.trades、dex.pools、candlesticks、token-prices、token-supplies）
  • 賬戶地址 —— 用於賬戶中心的 topic（balances、v1.transfers.proto）
同一合約或賬戶的事件按區塊順序落到同一分割槽。

​
Topic 矩陣

​
DEX 成交

TopicProto 訊息Schema 檔案描述
tron.dex.tradesTradeEventstron/trade_event.proto原始 DEX 成交（SunSwap、JustSwap 等）
tron.dex.trades.processedTradeEventstron/trade_event.proto附帶 USD / TRX 價格、可疑標記

​
代幣

TopicProto 訊息Schema 檔案描述
tron.tokensTokenEventstron/token_event.proto代幣生命週期事件
tron.tokens.processedTokenEventstron/token_event.proto補充描述、圖片、社交連結後的代幣

​
代幣級統計

TopicProto 訊息Schema 檔案描述
tron.token-pricesTokenPriceEventtron/token_price_event.proto聚合的價格更新（USD + TRX）
tron.token-suppliesTokenSupplyEventtron/token_supply_event.proto流通供給 + 總供給變化

​
餘額

TopicProto 訊息Schema 檔案描述
tron.balancesBalanceEventstron/balance_event.proto每個賬戶的原始餘額變化事件

​
DEX 池

TopicProto 訊息Schema 檔案描述
tron.dex.poolsDexPoolEventstron/dex_pool_event.proto池建立 / 更新 / sync 事件

​
轉賬

TopicProto 訊息Schema 檔案描述
tron.v1.transfers.protoTransfersMessagetron/transfers_message.proto所有 TRC-10 + TRC-20 + 原生幣轉賬
tron.v1.transfers.processed.protoTransfersMessagetron/transfers_message.proto附帶出塊時價格 + USD 數值的轉賬

​
K 線

TopicProto 訊息Schema 檔案描述
tron.candlesticksCandlestickEventscandlestick.proto多解析度預聚合的 OHLC

​
消費者示例

from confluent_kafka import Consumer
from streaming_protobuf.tron.trade_event_pb2 import TradeEvents

consumer = Consumer({
    "bootstrap.servers": "kafka.chainstream.io:9093",
    "security.protocol": "SASL_SSL",
    "sasl.mechanism": "SCRAM-SHA-512",
    "sasl.username": "<your-username>",
    "sasl.password": "<your-password>",
    "group.id": "my-consumer",
    "auto.offset.reset": "latest",
})
consumer.subscribe(["tron.dex.trades.processed"])

while True:
    msg = consumer.poll(1.0)
    if msg is None or msg.error():
        continue
    events = TradeEvents.FromString(msg.value())
    for trade in events.Trades:
        print(trade)
更多消費者示例見 Tron Streams 指南。

​
下一步

EVM Kafka Topics

Ethereum、BSC、Base、Polygon 等鏈的 topic 列表

Solana Kafka Topics

Solana 的 topic 列表

Kafka Streams 總覽

連線、鑑權、分割槽模型

Tron Streams 指南

欄位定義與消費者示例