EVM Kafka 主題

ChainStream 為每條 EVM 鏈釋出的 Kafka topic 權威列表。topic 命名使用 {chain} 字首——按你要消費的網路替換為 eth、bsc、base、polygon、optimism、arbitrum、avalanche 或 zksync。端到端的連線細節、SASL 憑證與 SDK 示例見接入方式 → Kafka Streams → EVM Streams。權威的 Protobuf 定義見 github.com/chainstream-io/streaming_protobuf/evm。

分割槽

所有 EVM topic 按以下其中之一分割槽：

代幣地址（bytes20）—— 用於代幣中心的 topic（tokens、dex.trades、dex.pools、candlesticks、token-prices、token-supplies、token-market-caps、trade-stats、token-holdings）
賬戶地址（bytes20）—— 用於賬戶中心的 topic（balances、v1.transfers.proto）

同一地址的事件按區塊順序落到同一分割槽——可以按分割槽水平擴充套件消費者。

Topic 矩陣

{chain} ∈ eth | bsc | base | polygon | optimism | arbitrum | avalanche | zksync（鏈可用性矩陣見 EVM Streams）。

DEX 成交

Topic	Proto 訊息	Schema 檔案	描述
`{chain}.dex.trades`	`TradeEvents`	`evm/trade_event.proto`	確認後即刻下發的原始 DEX 成交
`{chain}.dex.trades.processed`	`TradeEvents`	`evm/trade_event.proto`	同一批事件附帶 USD / 原生幣價格、可疑標記與去重

代幣

Topic	Proto 訊息	Schema 檔案	描述
`{chain}.tokens`	`TokenEvents`	`evm/token_event.proto`	代幣生命週期事件（建立、更新、遷移）
`{chain}.tokens.created`	`TokenEvents`	`evm/token_event.proto`	僅代幣建立事件的過濾流
`{chain}.tokens.processed`	`TokenEvents`	`evm/token_event.proto`	補充描述、圖片、社交連結後的代幣

代幣級統計

Topic	Proto 訊息	Schema 檔案	描述
`{chain}.token-prices`	`TokenPriceEvent`	`evm/token_price_event.proto`	聚合的價格更新（USD + 原生幣）
`{chain}.token-supplies`	`TokenSupplyEvent`	`evm/token_supply_event.proto`	流通供給 + 總供給變化
`{chain}.token-supplies.processed`	`TokenSupplyEvent`	`evm/token_supply_event.proto`	含小數點歸一化 + USD 數值的供給資料
`{chain}.token-market-caps.processed`	`TokenMarketCapEvent`	`evm/token_market_cap_event.proto`	市值（流通量 × 價格）
`{chain}.token-holdings`	`TokenHoldingEvent`	`evm/token_holding_event.proto`	持幣人數、Top-N 集中度
`{chain}.trade-stats`	`TradeStatEvent`	`evm/trade_stat_event.proto`	成交筆數、成交量、買家 / 賣家數

餘額

Topic	Proto 訊息	Schema 檔案	描述
`{chain}.balances`	`BalanceEvents`	`evm/balance_event.proto`	每個賬戶的原始餘額變化事件
`{chain}.balances.processed`	`BalanceEvents`	`evm/balance_event.proto`	帶 USD + 原生幣價值的餘額事件

DEX 池

Topic	Proto 訊息	Schema 檔案	描述
`{chain}.dex.pools`	`DexPoolEvents`	`evm/dex_pool_event.proto`	池建立 / 更新 / sync 事件
`{chain}.dex.pools.processed`	`DexPoolEvents`	`evm/dex_pool_event.proto`	附帶 USD + 原生幣流動性、費率檔的池事件

轉賬

Topic	Proto 訊息	Schema 檔案	描述
`{chain}.v1.transfers.proto`	`TransfersMessage`	`evm/transfers_message.proto`	所有代幣 + 原生幣轉賬（ERC-20 / ERC-721 / ERC-1155 / 原生）
`{chain}.v1.transfers.processed.proto`	`TransfersMessage`	`evm/transfers_message.proto`	附帶出塊時價格 + USD 數值的轉賬

K 線

Topic	Proto 訊息	Schema 檔案	描述
`{chain}.candlesticks`	`CandlestickEvents`	`candlestick.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 Streams 指南。

下一步

Solana Kafka Topics

Solana 的 topic 列表

Tron Kafka Topics

Tron 的 topic 列表

Kafka Streams 總覽

連線、鑑權、分割槽模型

EVM Streams 指南

欄位定義與消費者示例

鑑權

REST API

WebSocket

Kafka Topics

CLI 命令

MCP 工具

分割槽

Topic 矩陣

DEX 成交

代幣

代幣級統計

餘額

DEX 池

轉賬

K 線

消費者示例

下一步

Solana Kafka Topics

Tron Kafka Topics

Kafka Streams 總覽

EVM Streams 指南

​分割槽

​Topic 矩陣

​DEX 成交

​代幣

​代幣級統計

​餘額

​DEX 池

​轉賬

​K 線

​消費者示例

​下一步

Solana Kafka Topics

Tron Kafka Topics

Kafka Streams 總覽

EVM Streams 指南

分割槽

Topic 矩陣

DEX 成交

代幣

代幣級統計

餘額

DEX 池

轉賬

K 線

消費者示例

下一步