오픈 소스. 새로운 가능성.

franz-go를 래핑한 제한적 Apache Kafka 프로듀서, 컨슈머, 재재생, 검사, 트랜잭션 빌딩 블록을 제공하는 Go 라이브러리. 메시지 전달 결과, 라이프사이클 소유권, 토픽 정책을 숨기지 않음.

RisingWave는 데이터 수집, 처리, 서빙을 단일 시스템으로 통합하여 에이전트형 AI를 위해 설계된 이벤트 스트리밍 플랫폼입니다.

Redpanda와 PySpark Structured Streaming을 활용한 로컬 실시간 분석 파이프라인. Docker Compose로 클릭스트림 이벤트 시뮬레이션, 워터마킹 기반 시간 윈도우 집계 등을 구현한 교육용 프로젝트입니다.

Watermill은 Go로 이벤트 기반 애플리케이션을 구축하기 위한 라이브러리로, 메시지 스트림을 간단한 인터페이스로 추상화합니다. Kafka, RabbitMQ, NATS, Redis, SQL 등 다양한 Pub/Sub 구현을 지원합니다.

KEFCore는 Apache Kafka를 위한 Entity Framework Core 프로바이더로, .NET 애플리케이션이 Kafka 토픽을 분산 데이터베이스로 사용할 수 있게 합니다. 전체 LINQ 지원을 제공하며, 표준 EF Core 모델을 통해 Kafka와 상호 작용할 수 있도록 하여 Kafka 전용 클라이언트 코드를 추상화합니다.

Apache Kafka는 고성능 데이터 파이프라인, 스트리밍 분석 및 데이터 통합을 위해 설계된 오픈 소스 분산 이벤트 스트리밍 플랫폼입니다.

Pathway는 스트림 처리, 실시간 분석 및 LLM과 RAG 애플리케이션을 위한 Python ETL 프레임워크입니다. Rust 엔진 위에서 증분 계산을 수행하며 배치와 스트리밍 데이터를 동일한 코드로 처리하고 Docker 및 Kubernetes로 배포할 수 있습니다.