メインコンテンツへスキップ
Solana で配信される Kafka トピックの正式な一覧です。すべてのトピックは sol. プレフィックスを使用します。 エンドツーエンドの接続方法、SASL 認証情報、SDK の例については アクセス方法 → Kafka ストリーム → Solana ストリーム を参照してください。正式な Protobuf 定義は github.com/chainstream-io/streaming_protobuf/solana を参照してください。

​
パーティショニング

  • Mint アドレス（32 バイト pubkey、base58 エンコード） — トークン中心のトピック（tokens、dex.trades、dex.pools、candlesticks、token-prices、token-supplies、token-market-caps、trade-stats、token-holdings）
  • アカウントアドレス — アカウント中心のトピック（balances、transfers）
同じ mint／アカウントのイベントは同じパーティションに slot 順で到達します。

​
トピックマトリックス

​
DEX トレード

トピックProto メッセージスキーマファイル説明
sol.dex.tradesTradeEventssolana/trade_event.proto生の DEX スワップ（Raydium、Meteora、Pump.fun、Jupiter ルートなど）
sol.dex.trades.processedTradeEventssolana/trade_event.protoUSD／SOL 価格、ルーター解決、不審フラグを付与したもの

​
トークン

トピックProto メッセージスキーマファイル説明
sol.tokensTokenEventssolana/token_event.protoトークンライフサイクルイベント（mint、メタデータ更新、authority 変更）
sol.tokens.createdTokenEventssolana/token_event.protomint 作成イベントのみにフィルタしたストリーム
sol.tokens.processedTokenEventssolana/token_event.protoメタデータ JSON、image、socials を付与したトークン

​
トークンレベル統計

トピックProto メッセージスキーマファイル説明
sol.token-pricesTokenPriceEventsolana/token_price_event.proto集計済み価格更新（USD ＋ SOL）
sol.token-suppliesTokenSupplyEventsolana/token_supply_event.protoMint の supply 変化（mint／burn）
sol.token-supplies.processedTokenSupplyEventsolana/token_supply_event.proto小数正規化と USD 換算を付与した supply
sol.token-market-caps.processedTokenMarketCapEventsolana/token_market_cap_event.proto時価総額（流通量 × 価格）
sol.token-holdingsTokenHoldingEventsolana/token_holding_event.proto保有者数、トップ N 集中度
sol.trade-statsTradeStatEventsolana/trade_stat_event.proto取引数、出来高、ユニーク買い手／売り手

​
残高

トピックProto メッセージスキーマファイル説明
sol.balancesBalanceEventssolana/balance_event.protoアカウントごとの生の残高変動イベント
sol.balances.processedBalanceEventssolana/balance_event.protoUSD ＋ SOL 換算を付与した残高イベント

​
DEX プール

トピックProto メッセージスキーマファイル説明
sol.dex.poolsDexPoolEventssolana/dex_pool_event.protoプールの作成／更新／同期イベント（CLMM tick を含む）
sol.dex.pools.processedDexPoolEventssolana/dex_pool_event.proto流動性 USD ＋ SOL 換算と fee tier を付与したプールイベント

​
トランスファー

トピックProto メッセージスキーマファイル説明
sol.transfersTransferEventssolana/transfer_event.protoすべての SPL ＋ネイティブ転送（プログラム経由の転送を含む）
sol.transfers.processedTransferProcessedEventssolana/transfer_processed_event.protoslot 時点の価格と USD 換算を付与した転送

​
ローソク足

トピックProto メッセージスキーマファイル説明
sol.candlesticksCandlestickEventscandlestick.proto複数解像度で事前集計された OHLC

​
コンシューマ例

from confluent_kafka import Consumer
from streaming_protobuf.solana.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(["sol.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)
Go および JavaScript の等価例は Solana ストリームガイド を参照してください。

​
次へ

EVM Kafka トピック

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

Tron Kafka トピック

Tron のトピック一覧

Kafka ストリーム概要

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

Solana ストリームガイド

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