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

​
파티셔닝

  • 민트 주소 (32바이트 pubkey, base58 인코딩) — 토큰 중심 토픽(tokens, dex.trades, dex.pools, candlesticks, token-prices, token-supplies, token-market-caps, trade-stats, token-holdings)용
  • 계정 주소 — 계정 중심 토픽(balances, transfers)용
동일 민트 또는 계정의 이벤트는 슬롯 순서로 같은 파티션에 도착합니다.

​
토픽 매트릭스

​
DEX 거래

토픽Proto 메시지스키마 파일설명
sol.dex.tradesTradeEventssolana/trade_event.proto원시 DEX 스왑 (Raydium, Meteora, Pump.fun, Jupiter 라우트 등)
sol.dex.trades.processedTradeEventssolana/trade_event.protoUSD / SOL 가격, 라우터 해석, 의심 플래그로 보강

​
토큰

토픽Proto 메시지스키마 파일설명
sol.tokensTokenEventssolana/token_event.proto토큰 라이프사이클 이벤트 (민트, 메타데이터 업데이트, 권한 변경)
sol.tokens.createdTokenEventssolana/token_event.proto민트 생성 이벤트만 필터링한 스트림
sol.tokens.processedTokenEventssolana/token_event.proto메타데이터 JSON, 이미지, 소셜로 보강된 토큰

​
토큰 수준 통계

토픽Proto 메시지스키마 파일설명
sol.token-pricesTokenPriceEventsolana/token_price_event.proto집계된 가격 업데이트 (USD + SOL)
sol.token-suppliesTokenSupplyEventsolana/token_supply_event.proto민트 공급량 변동 (민트/번)
sol.token-supplies.processedTokenSupplyEventsolana/token_supply_event.proto소수점 정규화 + USD 가치가 적용된 공급량
sol.token-market-caps.processedTokenMarketCapEventsolana/token_market_cap_event.proto시가총액 (유통량 × 가격)
sol.token-holdingsTokenHoldingEventsolana/token_holding_event.proto홀더 수, 상위 N 집중도
sol.trade-statsTradeStatEventsolana/trade_stat_event.proto거래 수, 거래량, 고유 매수자 / 매도자

​
잔고

토픽Proto 메시지스키마 파일설명
sol.balancesBalanceEventssolana/balance_event.proto계정별 원시 잔고 변동 이벤트
sol.balances.processedBalanceEventssolana/balance_event.protoUSD + SOL 가치가 포함된 잔고 이벤트

​
DEX 풀

토픽Proto 메시지스키마 파일설명
sol.dex.poolsDexPoolEventssolana/dex_pool_event.proto풀 생성 / 업데이트 / 동기화 이벤트 (CLMM 틱 포함)
sol.dex.pools.processedDexPoolEventssolana/dex_pool_event.proto유동성 USD + SOL과 수수료 티어로 보강된 풀 이벤트

​
전송

토픽Proto 메시지스키마 파일설명
sol.transfersTransferEventssolana/transfer_event.proto프로그램 호출 전송을 포함한 모든 SPL + 네이티브 전송
sol.transfers.processedTransferProcessedEventssolana/transfer_processed_event.proto슬롯 시점 가격 + USD 가치로 보강된 전송

​
캔들스틱

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

​
컨슈머 예시

from confluent_kafka import Consumer
from streaming_protobuf.solana.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(["sol.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)
Go와 JavaScript 동등 예시는 Solana Streams 가이드를 참고하세요.

​
다음 단계

EVM Kafka 토픽

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

Tron Kafka 토픽

Tron의 토픽 목록

Kafka Streams 개요

연결, 인증, 파티션 모델

Solana Streams 가이드

필드 정의 및 컨슈머 예시