Solana Kafka 토픽

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.trades`	`TradeEvents`	`solana/trade_event.proto`	원시 DEX 스왑 (Raydium, Meteora, Pump.fun, Jupiter 라우트 등)
`sol.dex.trades.processed`	`TradeEvents`	`solana/trade_event.proto`	USD / SOL 가격, 라우터 해석, 의심 플래그로 보강

토큰

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

토큰 수준 통계

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

잔고

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

DEX 풀

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

전송

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

캔들스틱

토픽	Proto 메시지	스키마 파일	설명
`sol.candlesticks`	`CandlestickEvents`	`candlestick.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 가이드

필드 정의 및 컨슈머 예시

인증

REST API

WebSocket

Kafka Topics

CLI 명령어

MCP 도구

파티셔닝

토픽 매트릭스

DEX 거래

토큰

토큰 수준 통계

잔고

DEX 풀

전송

캔들스틱

컨슈머 예시

다음 단계

EVM Kafka 토픽

Tron Kafka 토픽

Kafka Streams 개요

Solana Streams 가이드

​파티셔닝

​토픽 매트릭스

​DEX 거래

​토큰

​토큰 수준 통계

​잔고

​DEX 풀

​전송

​캔들스틱

​컨슈머 예시

​다음 단계

EVM Kafka 토픽

Tron Kafka 토픽

Kafka Streams 개요

Solana Streams 가이드

파티셔닝

토픽 매트릭스

DEX 거래

토큰

토큰 수준 통계

잔고

DEX 풀

전송

캔들스틱

컨슈머 예시

다음 단계