스키마 레지스트리 사용하기

Pulsar에는 내장 스키마 레지스트리(schema registry)가 있고 인기 있는 스키마 타입들이 함께 번들되어 있어요. Pulsar 함수는 입력 토픽의 기존 스키마 정보를 활용해 입력 타입을 자동으로 유추할 수 있고, 출력 토픽에도 스키마 레지스트리가 적용돼요.

즉, 함수의 입력·출력 타입을 스키마로 명확히 정의해서 데이터를 더 안전하고 타입 안전하게 주고받을 수 있어요. 언어별로 지원되는 스키마 타입이 다르니 표를 꼭 확인해 두세요.

출처: 문서

본문

아래 표는 Pulsar 함수에서 지원하는 스키마 타입을 정리한 거예요.

스키마 타입	Java 함수	Python 함수
String	✅	✅
Avro	✅	✅
JSON	✅	✅
Protobuf	✅
ProtobufNative	✅
Key/Value	✅
AUTO_PRODUCE	✅
AUTO_CONSUME	✅

더 많은 코드 예시는 Java 함수와 Python 함수 문서를 참고해요.

더 알아보기 (Learn more)

스키마의 개념과 종류가 궁금하다면 Pulsar 스키마 개요 문서를 살펴보세요.
SerDe를 활용해 함수의 데이터를 직렬화하는 방법은 함수 SerDe 문서를 참고해요.
스키마 레지스트리 관리 명령은 스키마 관리 문서에서 확인할 수 있어요.