warpstreamlabs/bento

어떤 프로젝트인가요?

핵심 기능

• 01Kafka, NATS, Redis, AWS, GCP, Azure, SQL 데이터베이스 등을 입력 및 출력으로 연결합니다.
• 02내장 매핑 언어인 Bloblang을 사용해 YAML로 파이프라인을 선언합니다.
• 03소스와 싱크가 지원하는 경우 디스크 상태 없이 at-least-once 전달을 제공합니다.
• 04정적 바이너리, Docker 이미지 또는 서버리스 함수 형태로 제공됩니다.
• 05/ping 및 /ready 상태 확인 엔드포인트와 Prometheus, Statsd, OpenTelemetry 관측 기능을 제공합니다.
• 06Go 플러그인으로 작성한 커스텀 컴포넌트를 지원합니다.

활용 사례

• Kafka 또는 NATS의 이벤트를 간단히 변환해 데이터베이스나 검색 인덱스로 옮기기.
• 다운스트림 서비스에 도달하기 전에 메시지 스트림을 보강하거나 필터링하기.
• AWS Kinesis 또는 GCP Pub/Sub 같은 클라우드 서비스를 다른 브로커와 연결하기.
• 더 무거운 스트림 플랫폼을 운영하지 않고 가벼운 컨테이너 기반 파이프라인 실행하기.

빠른 시작

1. 1

   Docker 이미지를 pull합니다

   docker pull ghcr.io/warpstreamlabs/bento
2. 2

   설정 파일을 마운트하고 Docker에서 Bento를 실행합니다

   docker run --rm -v /path/to/your/config.yaml:/bento.yaml ghcr.io/warpstreamlabs/bento

사용 전 알아둘 점

• !README에 따르면 릴리스 프로세스가 아직 진행 중이므로 표준 바이너리 설치 방법은 없습니다.
• !프로젝트 메타데이터에 라이선스가 명확히 표시되어 있지 않습니다.
• !일부 구성 요소에는 zmq4와 같은 특수 빌드 태그와 외부 C 라이브러리가 필요합니다.

토픽

자주 묻는 질문

bento은(는) 무엇인가요?

메시지 브로커, 클라우드 서비스, 데이터베이스를 연결하고 중간에 매핑 언어로 페이로드를 변환하는 Go 스트림 프로세서입니다. Bento는 Go로 작성된 스트림 프로세서입니다. Kafka, NATS, Redis streams, AWS 및 GCP 서비스, SQL 데이터베이스 같은 소스에서 데이터를 읽고, 프로세서 체인을 거쳐 싱크에 씁니다. 파이프라인은 YAML로 선언하므로 기본 설정은 구성 파일 하나로 작성할 수 있습니다.

bento은(는) 무료로 사용할 수 있나요? 라이선스는 무엇인가요?

bento은(는) Other 라이선스의 오픈소스입니다. 상업용 제품에 사용하기 전에 라이선스 조건을 확인하세요.

bento은(는) 아직 유지보수되고 있나요?

활발히 유지보수 중. bento의 마지막 커밋은 2026년 10월 17일입니다.

bento은(는) 어디에 사용할 수 있나요?

Kafka 또는 NATS의 이벤트를 간단히 변환해 데이터베이스나 검색 인덱스로 옮기기. 다운스트림 서비스에 도달하기 전에 메시지 스트림을 보강하거나 필터링하기. AWS Kinesis 또는 GCP Pub/Sub 같은 클라우드 서비스를 다른 브로커와 연결하기. 더 무거운 스트림 플랫폼을 운영하지 않고 가벼운 컨테이너 기반 파이프라인 실행하기.

bento는 어떻게 설치하나요?

Docker 이미지를 pull합니다: docker pull ghcr.io/warpstreamlabs/bento 설정 파일을 마운트하고 Docker에서 Bento를 실행합니다: docker run --rm -v /path/to/your/config.yaml:/bento.yaml ghcr.io/warpstreamlabs/bento

bento은(는) 어디서 받을 수 있나요?

소스 코드와 설치 방법은 GitHub에 있습니다: https://github.com/warpstreamlabs/bento