メインコンテンツへスキップ
Tron で配信される Kafka トピックの正式な一覧です。すべてのトピックは tron. プレフィックスを使用します。 エンドツーエンドの接続方法、SASL 認証情報、SDK の例については アクセス方法 → Kafka ストリーム → Tron ストリーム を参照してください。正式な 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 メッセージスキーマファイル説明
tron.dex.tradesTradeEventstron/trade_event.proto生の DEX スワップ（SunSwap、JustSwap など）
tron.dex.trades.processedTradeEventstron/trade_event.protoUSD／TRX 価格と不審フラグを付与したもの

​
トークン

トピックProto メッセージスキーマファイル説明
tron.tokensTokenEventstron/token_event.protoトークンライフサイクルイベント
tron.tokens.processedTokenEventstron/token_event.protodescription、image、social link を付与したトークン

​
トークンレベル統計

トピックProto メッセージスキーマファイル説明
tron.token-pricesTokenPriceEventtron/token_price_event.proto集計済み価格更新（USD ＋ TRX）
tron.token-suppliesTokenSupplyEventtron/token_supply_event.proto流通量＋総供給量の変化

​
残高

トピックProto メッセージスキーマファイル説明
tron.balancesBalanceEventstron/balance_event.protoアカウントごとの生の残高変動イベント

​
DEX プール

トピックProto メッセージスキーマファイル説明
tron.dex.poolsDexPoolEventstron/dex_pool_event.protoプールの作成／更新／同期イベント

​
トランスファー

トピックProto メッセージスキーマファイル説明
tron.v1.transfers.protoTransfersMessagetron/transfers_message.protoすべての TRC-10 ＋ TRC-20 ＋ネイティブ転送
tron.v1.transfers.processed.protoTransfersMessagetron/transfers_message.protoブロック時点の価格と USD 換算を付与した転送

​
ローソク足

トピックProto メッセージスキーマファイル説明
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 ストリームガイド を参照してください。

​
次へ

EVM Kafka トピック

Ethereum、BSC、Base、Polygon などのトピック一覧

Solana Kafka トピック

Solana のトピック一覧

Kafka ストリーム概要

接続、認証、パーティションモデル

Tron ストリームガイド

フィールド定義とコンシューマ例