Skip to main content
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

TopicProto messageSchema fileDescription
tron.dex.tradesTradeEventstron/trade_event.protoRaw DEX swaps (SunSwap, JustSwap, etc.)
tron.dex.trades.processedTradeEventstron/trade_event.protoEnriched with USD / TRX price, suspect flags

​
Tokens

TopicProto messageSchema fileDescription
tron.tokensTokenEventstron/token_event.protoToken lifecycle events
tron.tokens.processedTokenEventstron/token_event.protoTokens enriched with description, image, social links

​
Token-level statistics

TopicProto messageSchema fileDescription
tron.token-pricesTokenPriceEventtron/token_price_event.protoAggregated price updates (USD + TRX)
tron.token-suppliesTokenSupplyEventtron/token_supply_event.protoCirculating + total supply changes

​
Balances

TopicProto messageSchema fileDescription
tron.balancesBalanceEventstron/balance_event.protoRaw balance-change events per account

​
DEX pools

TopicProto messageSchema fileDescription
tron.dex.poolsDexPoolEventstron/dex_pool_event.protoPool create / update / sync events

​
Transfers

TopicProto messageSchema fileDescription
tron.v1.transfers.protoTransfersMessagetron/transfers_message.protoAll TRC-10 + TRC-20 + native transfers
tron.v1.transfers.processed.protoTransfersMessagetron/transfers_message.protoTransfers enriched with price-at-block + USD value

​
Candlesticks

TopicProto messageSchema fileDescription
tron.candlesticksCandlestickEventscandlestick.protoPre-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