토픽과 구독의 선택
응용은 토픽을 통해 메시지를 보내고 구독한다. 독점과 공유 및 장애 전환과 키 기반 공유 같은 구독 유형을 제공하므로 소비자들이 메시지를 나누어 처리하는 방식을 선택할 수 있다.
보관과 여러 클러스터의 연결
메시지의 영구 저장에는 Apache BookKeeper를 활용한다. 여러 클러스터 사이에서 메시지를 복제하는 기능과 시간이 지난 자료를 장기 저장 계층으로 옮기는 계층형 저장도 제공한다.
처리 함수와 자료 연결
Pulsar Functions는 메시지 흐름 안에서 자료를 처리하는 함수를 실행한다. Pulsar IO는 외부 시스템과 메시지를 주고받는 커넥터를 구성하는 기능이다. 메시지의 전달과 그 주변의 자료 처리 흐름을 함께 연결한다.
관련 문서
Apache Kafka / Apache Samza / Apache Flink / CloudEvents / AsyncAPI / OpenTelemetry