Tron Kafka Topics

Authoritative list of Kafka topics published for Tron. All topics use the tron. prefix. For end-to-end connection details, SASL credentials, and SDK examples see Access Methods → Kafka Streams → Tron Streams. For the authoritative Protobuf definitions see github.com/chainstream-io/streaming_protobuf/tron.

Partitioning

Token address (base58-encoded TRC-20 contract address) — for token-centric topics (tokens, dex.trades, dex.pools, candlesticks, token-prices, token-supplies)
Account address — for account-centric topics (balances, v1.transfers.proto)

Events for the same contract or account land on the same partition in block order.

Topic matrix

DEX trades

Topic	Proto message	Schema file	Description
`tron.dex.trades`	`TradeEvents`	`tron/trade_event.proto`	Raw DEX swaps (SunSwap, JustSwap, etc.)
`tron.dex.trades.processed`	`TradeEvents`	`tron/trade_event.proto`	Enriched with USD / TRX price, suspect flags

Tokens

Topic	Proto message	Schema file	Description
`tron.tokens`	`TokenEvents`	`tron/token_event.proto`	Token lifecycle events
`tron.tokens.processed`	`TokenEvents`	`tron/token_event.proto`	Tokens enriched with description, image, social links

Token-level statistics

Topic	Proto message	Schema file	Description
`tron.token-prices`	`TokenPriceEvent`	`tron/token_price_event.proto`	Aggregated price updates (USD + TRX)
`tron.token-supplies`	`TokenSupplyEvent`	`tron/token_supply_event.proto`	Circulating + total supply changes

Balances

Topic	Proto message	Schema file	Description
`tron.balances`	`BalanceEvents`	`tron/balance_event.proto`	Raw balance-change events per account

DEX pools

Topic	Proto message	Schema file	Description
`tron.dex.pools`	`DexPoolEvents`	`tron/dex_pool_event.proto`	Pool create / update / sync events

Transfers

Topic	Proto message	Schema file	Description
`tron.v1.transfers.proto`	`TransfersMessage`	`tron/transfers_message.proto`	All TRC-10 + TRC-20 + native transfers
`tron.v1.transfers.processed.proto`	`TransfersMessage`	`tron/transfers_message.proto`	Transfers enriched with price-at-block + USD value

Candlesticks

Topic	Proto message	Schema file	Description
`tron.candlesticks`	`CandlestickEvents`	`candlestick.proto`	Pre-aggregated OHLC across multiple resolutions

Example consumer

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)

See the Tron Streams guide for additional consumer examples.

EVM Kafka Topics

Topic list for Ethereum, BSC, Base, Polygon and more

Solana Kafka Topics

Topic list for Solana

Kafka Streams overview

Connection, auth, partition model

Tron Streams guide

Field definitions and consumer examples

Authentication

REST API

WebSocket

Kafka Topics

CLI Commands

MCP Tools

Partitioning

Topic matrix

DEX trades

Tokens

Token-level statistics

Balances

DEX pools

Transfers

Candlesticks

Example consumer

Next

EVM Kafka Topics

Solana Kafka Topics

Kafka Streams overview

Tron Streams guide

​Partitioning

​Topic matrix

​DEX trades

​Tokens

​Token-level statistics

​Balances

​DEX pools

​Transfers

​Candlesticks

​Example consumer

​Next

EVM Kafka Topics

Solana Kafka Topics

Kafka Streams overview

Tron Streams guide

Partitioning

Topic matrix

DEX trades

Tokens

Token-level statistics

Balances

DEX pools

Transfers

Candlesticks

Example consumer

Next