跳转到主要内容
ChainStream 为每条 EVM 链发布的 Kafka 主题的权威列表。主题名以 {chain} 开头——把它替换成你要消费的网络：eth、bsc、base、polygon、optimism、arbitrum、avalanche 或 zksync。 端到端连接细节、SASL 凭证与 SDK 示例请参考 接入方式 → Kafka Streams → EVM Streams。权威的 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 Streams）。

​
DEX 成交

主题Proto 消息Schema 文件说明
{chain}.dex.tradesTradeEventsevm/trade_event.proto确认后立即推出的原始 DEX swap
{chain}.dex.trades.processedTradeEventsevm/trade_event.proto同样的事件，叠加 USD / 原生币价格、可疑标志与去重

​
代币

主题Proto 消息Schema 文件说明
{chain}.tokensTokenEventsevm/token_event.proto代币生命周期事件（创建、更新、迁移）
{chain}.tokens.createdTokenEventsevm/token_event.proto只包含代币创建事件的过滤流
{chain}.tokens.processedTokenEventsevm/token_event.proto代币 + 描述、图像、社交链接等增强字段

​
代币级统计

主题Proto 消息Schema 文件说明
{chain}.token-pricesTokenPriceEventevm/token_price_event.proto聚合后的价格更新（USD + 原生币）
{chain}.token-suppliesTokenSupplyEventevm/token_supply_event.proto流通量 + 总供应量变化
{chain}.token-supplies.processedTokenSupplyEventevm/token_supply_event.proto供应量（按 decimal 规整 + USD 计价）
{chain}.token-market-caps.processedTokenMarketCapEventevm/token_market_cap_event.proto市值（流通量 × 价格）
{chain}.token-holdingsTokenHoldingEventevm/token_holding_event.proto持币人数、Top-N 集中度
{chain}.trade-statsTradeStatEventevm/trade_stat_event.proto成交次数、成交量、买卖方数

​
余额

主题Proto 消息Schema 文件说明
{chain}.balancesBalanceEventsevm/balance_event.proto各账户原始余额变更事件
{chain}.balances.processedBalanceEventsevm/balance_event.proto余额事件 + USD / 原生币计价

​
DEX 池子

主题Proto 消息Schema 文件说明
{chain}.dex.poolsDexPoolEventsevm/dex_pool_event.proto池子创建 / 更新 / sync 事件
{chain}.dex.pools.processedDexPoolEventsevm/dex_pool_event.proto池事件 + USD / 原生币流动性、费率档

​
转账

主题Proto 消息Schema 文件说明
{chain}.v1.transfers.protoTransfersMessageevm/transfers_message.proto全量代币 + 原生币转账（ERC-20 / ERC-721 / ERC-1155 / 原生币）
{chain}.v1.transfers.processed.protoTransfersMessageevm/transfers_message.proto转账 + 区块时价格 + USD 计价

​
K 线

主题Proto 消息Schema 文件说明
{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 Streams 指南。

​
下一步

Solana Kafka 主题

Solana 的主题列表

Tron Kafka 主题

Tron 的主题列表

Kafka Streams 总览

连接、认证、分区模型

EVM Streams 指南

字段定义与消费者示例