Tron Kafka 主题

Tron Kafka 主题名称、分区键和 payload schema 的参考列表。

ChainStream 为 Tron 发布的 Kafka 主题的权威列表。所有主题都以 tron. 为前缀。

端到端连接细节、SASL 凭证与 SDK 示例请参考 接入方式 → Kafka Streams → Tron Streams。权威的 Protobuf 定义见 github.com/chainstream-io/streaming_protobuf/tron。

​

分区

• 代币地址（base58 编码的 TRC-20 合约地址）——代币维度的主题（tokens、dex.trades、dex.pools、candlesticks、token-prices、token-supplies）
• 账户地址——账户维度的主题（balances、v1.transfers.proto）

同一合约或账户的事件按区块顺序落入同一分区。

​

主题矩阵

​

DEX 成交

主题	Proto 消息	Schema 文件	说明
tron.dex.trades	TradeEvents	tron/trade_event.proto	原始 DEX swap（SunSwap、JustSwap 等）
tron.dex.trades.processed	TradeEvents	tron/trade_event.proto	叠加 USD / TRX 价格、可疑标志

​

代币

主题	Proto 消息	Schema 文件	说明
tron.tokens	TokenEvents	tron/token_event.proto	代币生命周期事件
tron.tokens.processed	TokenEvents	tron/token_event.proto	代币 + 描述、图像、社交链接

​

代币级统计

主题	Proto 消息	Schema 文件	说明
tron.token-prices	TokenPriceEvent	tron/token_price_event.proto	聚合价格更新（USD + TRX）
tron.token-supplies	TokenSupplyEvent	tron/token_supply_event.proto	流通量 + 总供应量变化

​

余额

主题	Proto 消息	Schema 文件	说明
tron.balances	BalanceEvents	tron/balance_event.proto	各账户原始余额变更事件

​

DEX 池子

主题	Proto 消息	Schema 文件	说明
tron.dex.pools	DexPoolEvents	tron/dex_pool_event.proto	池子创建 / 更新 / sync 事件

​

转账

主题	Proto 消息	Schema 文件	说明
tron.v1.transfers.proto	TransfersMessage	tron/transfers_message.proto	全量 TRC-10 + TRC-20 + 原生币转账
tron.v1.transfers.processed.proto	TransfersMessage	tron/transfers_message.proto	转账 + 区块时价格 + USD 计价

​

K 线

主题	Proto 消息	Schema 文件	说明
tron.candlesticks	CandlestickEvents	candlestick.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 主题

Ethereum、BSC、Base、Polygon 等的主题列表

Solana Kafka 主题

Solana 的主题列表

Kafka Streams 总览

连接、认证、分区模型

Tron Streams 指南

字段定义与消费者示例