メインコンテンツへスキップ
ChainStream がインデックスする各 EVM チェーンで配信される Kafka トピックの正式な一覧です。トピック名は {chain} プレフィックスを使用します — 対象ネットワークに応じて eth、bsc、base、polygon、optimism、arbitrum、avalanche、zksync に置き換えてください。 エンドツーエンドの接続方法、SASL 認証情報、SDK の例については アクセス方法 → Kafka ストリーム → EVM ストリーム を参照してください。正式な Protobuf 定義は github.com/chainstream-io/streaming_protobuf/evm を参照してください。

​
パーティショニング

すべての EVM トピックは次のいずれかでパーティショニングされます：
  • トークンアドレス（bytes20） — トークン中心のトピック（tokens、dex.trades、dex.pools、candlesticks、token-prices、token-supplies、token-market-caps、trade-stats、token-holdings）
  • アカウントアドレス（bytes20） — アカウント中心のトピック（balances、v1.transfers.proto）
同じアドレスのイベントは同じパーティションにブロック順で到達するため、パーティション単位でコンシューマを水平スケールしても安全です。

​
トピックマトリックス

{chain} ∈ eth | bsc | base | polygon | optimism | arbitrum | avalanche | zksync（チェーン提供状況は EVM ストリーム のマトリックスを参照）。

​
DEX トレード

トピックProto メッセージスキーマファイル説明
{chain}.dex.tradesTradeEventsevm/trade_event.proto確定時に送出される生の DEX スワップ
{chain}.dex.trades.processedTradeEventsevm/trade_event.proto上記に USD／ネイティブ価格、不審フラグ、重複排除を加えたもの

​
トークン

トピックProto メッセージスキーマファイル説明
{chain}.tokensTokenEventsevm/token_event.protoトークンライフサイクルイベント（create、update、migrate）
{chain}.tokens.createdTokenEventsevm/token_event.protoトークン作成イベントのみにフィルタしたストリーム
{chain}.tokens.processedTokenEventsevm/token_event.protodescription、image、social link を付与したトークン

​
トークンレベル統計

トピックProto メッセージスキーマファイル説明
{chain}.token-pricesTokenPriceEventevm/token_price_event.proto集計済み価格更新（USD ＋ネイティブ）
{chain}.token-suppliesTokenSupplyEventevm/token_supply_event.proto流通量＋総供給量の変化
{chain}.token-supplies.processedTokenSupplyEventevm/token_supply_event.proto小数正規化と USD 換算を付与した supply
{chain}.token-market-caps.processedTokenMarketCapEventevm/token_market_cap_event.proto時価総額（流通量 × 価格）
{chain}.token-holdingsTokenHoldingEventevm/token_holding_event.proto保有者数、トップ N 集中度
{chain}.trade-statsTradeStatEventevm/trade_stat_event.proto取引数、出来高、買い手／売り手

​
残高

トピックProto メッセージスキーマファイル説明
{chain}.balancesBalanceEventsevm/balance_event.protoアカウントごとの生の残高変動イベント
{chain}.balances.processedBalanceEventsevm/balance_event.protoUSD ＋ネイティブ換算を付与した残高イベント

​
DEX プール

トピックProto メッセージスキーマファイル説明
{chain}.dex.poolsDexPoolEventsevm/dex_pool_event.protoプールの作成／更新／同期イベント
{chain}.dex.pools.processedDexPoolEventsevm/dex_pool_event.proto流動性 USD ＋ネイティブ換算、fee tier を付与したプールイベント

​
トランスファー

トピックProto メッセージスキーマファイル説明
{chain}.v1.transfers.protoTransfersMessageevm/transfers_message.protoすべてのトークン＋ネイティブ転送（ERC-20 / ERC-721 / ERC-1155 / native）
{chain}.v1.transfers.processed.protoTransfersMessageevm/transfers_message.protoブロック時点の価格と USD 換算を付与した転送

​
ローソク足

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

​
コンシューマ例

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

​
次へ

Solana Kafka トピック

Solana のトピック一覧

Tron Kafka トピック

Tron のトピック一覧

Kafka ストリーム概要

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

EVM ストリームガイド

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