Tron Kafka Topics

Reference list of Tron Kafka topic names, partition keys and payload schemas.

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.

Next

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