메인 콘텐츠로 건너뛰기
Tron에 대해 발행되는 Kafka 토픽의 권위 있는 목록입니다. 모든 토픽은 tron. 접두사를 사용합니다. 엔드투엔드 연결 상세, SASL 크리덴셜, SDK 예시는 접근 방식 → Kafka Streams → Tron Streams를 참고하세요. 권위 있는 Protobuf 정의는 github.com/chainstream-io/streaming_protobuf/tron을 참고하세요.

​
파티셔닝

  • 토큰 주소 (base58 인코딩된 TRC-20 컨트랙트 주소) — 토큰 중심 토픽(tokens, dex.trades, dex.pools, candlesticks, token-prices, token-supplies)용
  • 계정 주소 — 계정 중심 토픽(balances, v1.transfers.proto)용
동일 컨트랙트 또는 계정의 이벤트는 블록 순서로 같은 파티션에 도착합니다.

​
토픽 매트릭스

​
DEX 거래

토픽Proto 메시지스키마 파일설명
tron.dex.tradesTradeEventstron/trade_event.proto원시 DEX 스왑 (SunSwap, JustSwap 등)
tron.dex.trades.processedTradeEventstron/trade_event.protoUSD / TRX 가격, 의심 플래그로 보강

​
토큰

토픽Proto 메시지스키마 파일설명
tron.tokensTokenEventstron/token_event.proto토큰 라이프사이클 이벤트
tron.tokens.processedTokenEventstron/token_event.proto설명, 이미지, 소셜 링크로 보강된 토큰

​
토큰 수준 통계

토픽Proto 메시지스키마 파일설명
tron.token-pricesTokenPriceEventtron/token_price_event.proto집계된 가격 업데이트 (USD + TRX)
tron.token-suppliesTokenSupplyEventtron/token_supply_event.proto유통 + 총 공급량 변동

​
잔고

토픽Proto 메시지스키마 파일설명
tron.balancesBalanceEventstron/balance_event.proto계정별 원시 잔고 변동 이벤트

​
DEX 풀

토픽Proto 메시지스키마 파일설명
tron.dex.poolsDexPoolEventstron/dex_pool_event.proto풀 생성 / 업데이트 / 동기화 이벤트

​
전송

토픽Proto 메시지스키마 파일설명
tron.v1.transfers.protoTransfersMessagetron/transfers_message.proto모든 TRC-10 + TRC-20 + 네이티브 전송
tron.v1.transfers.processed.protoTransfersMessagetron/transfers_message.proto블록 시점 가격 + USD 가치로 보강된 전송

​
캔들스틱

토픽Proto 메시지스키마 파일설명
tron.candlesticksCandlestickEventscandlestick.proto여러 해상도에 걸친 사전 집계 OHLC

​
컨슈머 예시

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)
추가 컨슈머 예시는 Tron Streams 가이드를 참고하세요.

​
다음 단계

EVM Kafka 토픽

Ethereum, BSC, Base, Polygon 등의 토픽 목록

Solana Kafka 토픽

Solana의 토픽 목록

Kafka Streams 개요

연결, 인증, 파티션 모델

Tron Streams 가이드

필드 정의 및 컨슈머 예시