SLASH 22 - 토스증권 실시간 시세 적용기 (Kafka, WebSocket)

 

TL;DR

- 웹소켓을 사용해 실시간 정보를 제공한다. (풀링 방식 사용 고려했으나 취소)

- 연결 정보는 Redis 에 넣는다.

- Kafka Acks 는 1을 사용해서 속도를 높이고, 프로듀서 컨슈머 양쪽 고려해 가장 빠른 lz4 를 사용한다.

- WebSocket Connection Leak 은 정상 종료 외 비정상 종료 시에도 연결 끊어줘야한다.

 

 

 

 

 

 

 

 

 

 

 

 

 

- 에러 코드일 때도 닫아줘야한다.