Xkafka

Go에서 Kafka를 더 쉽게 사용하는 방법

About

xkafka는 Go 환경에서 Kafka를 HTTP 서비스처럼 단순하게 사용할 수 있도록 해주는 오픈소스 라이브러리
기존 confluent-kafka-go 사용 시 복잡한 처리 루프와 많은 보일러플레이트 코드가 필요했지만, xkafka는 Handler, Middleware, Message 구조로 핵심 로직에 집중할 수 있게 해줌
메시지 발행과 소비를 HTTP 요청/응답 방식처럼 직관적으로 처리하며, 오프셋 관리, 동시성 설정, 에러 핸들링 등 Kafka의 복잡함을 많이 감춰줌
Streaming/Batch 처리, 순차/비동기 처리, At-most-once/At-least-once 보장 등 실서비스에서 요구되는 다양한 패턴을 간단히 지원함
계층적 에러 처리, 미들웨어 기반 재시도/로깅/메트릭스 등 실무에 필요한 패턴을 쉽게 적용할 수 있음