BackendFlink SQL 도입기
이 글은 Azar Matching Dev Team에서 이벤트 스트리밍 처리를 위해 Flink SQL을 도입한 경험을 공유합니다. 기존에 Kafka를 소스 및 싱크로 사용하는 애플리케이션 코드를 직접 작성하는 방식으로 Flink를 활용했으나, CPU 사용량이 높고 유지보수가 어려운 레거시 Flink 앱의 문제에 직면했습니다. 이 앱은 여러 매치 이벤트를 조인하고 조건부 로직을 수행하는 모놀리식 구조였으며, 인프라 변경으로 인해 정상 동작하지 않는 문제가 발생했습니다. 이를 해결하기 위해 Flink SQL을 도입하여 SQL만으로 이벤트 스트리밍 처리를 구현하는 방안을 모색했습니다. Flink SQL은 애플리케이션 코드 작성 없이 SQL 쿼리로 스트리밍 앱을 개발할 수 있게 하여, 레거시 시스템의 유지보수 부담을 줄이고 효율성을 높일 수 있는 대안으로 제시됩니다. 글에서는 Flink SQL 도입 이유와 클러스터 구축 및 운영 경험을 다룹니다.

