8.3. 다른 클라이언트 직렬화기/deserializer 유형을 구성하는 방법

Avro serializer 구성

다음을 사용하여 Avro serializer 클래스를 구성할 수 있습니다.

ID 위치

직렬화기에서 스키마의 고유 ID를 Kafka 메시지의 일부로 전달하여 소비자가 deserialization에 올바른 스키마를 사용할 수 있습니다. ID는 메시지 페이로드 또는 메시지 헤더에 있을 수 있습니다. 기본 위치는 메시지 페이로드입니다. 메시지 헤더에 ID를 보내려면 다음 구성 속성을 설정합니다.

ID 인코딩

Kafka 메시지 본문에 전달할 때 스키마 ID를 인코딩하는 방법을 사용자 지정할 수 있습니다. apicurio.registry.id-handler 구성 속성을 io.apicurio.registry.serde.IdHandler 인터페이스를 구현하는 클래스로 설정합니다. Service Registry에서는 다음과 같은 구현을 제공합니다.

Avro datum 공급자

Avro는 다양한 datum 작성자와 리더를 제공하여 데이터를 작성하고 읽을 수 있습니다. Service Registry에서는 다음 세 가지 유형을 지원합니다.

Avro 인코딩

Avro를 사용하여 데이터를 직렬화할 때 Avro 바이너리 인코딩 형식을 사용하여 데이터가 가능한 한 효율적으로 인코딩되도록 할 수 있습니다. 또한 Avro는 JSON으로 데이터 인코딩을 지원하므로 각 메시지의 페이로드를 더 쉽게 검사할 수 있습니다(예: 로깅 또는 디버깅).

Avro deserializer 구성

serializer의 다음 구성 설정과 일치하도록 Avro deserializer 클래스를 구성해야 합니다.

Avro SerDes 및 아티팩트 참조

Avro 메시지 및 중첩 레코드가 포함된 스키마로 작업할 때 중첩 레코드별로 새 아티팩트가 등록됩니다. 예를 들어, 다음 involves Key 스키마에는 중첩된 Exchange 스키마가 포함되어 있습니다.

TRADEKEY 스키마 중첩 Exchange 스키마

{
  "namespace": "com.kubetrade.schema.trade",
  "type": "record",
  "name": "TradeKey",
  "fields": [
    {
      "name": "exchange",
      "type": "com.kubetrade.schema.common.Exchange"
    },
    {
      "name": "key",
      "type": "string"
    }
  ]
}

교환 스키마

{
  "namespace": "com.kubetrade.schema.common",
  "type": "enum",
  "name": "Exchange",
  "symbols" : ["GEMINI"]
}

JSON Schema serializer 구성

다음과 같이 JSON Schema serializer 클래스를 구성할 수 있습니다.

JSON Schema deserializer 구성

다음과 같이 JSON Schema deserializer 클래스를 구성할 수 있습니다.

JSON Schema SerDes 및 아티팩트 참조

JSON Schema SerDes는 메시지 페이로드에서 스키마를 검색할 수 없으므로 스키마 아티팩트를 미리 등록해야 하며 아티팩트 참조도 적용합니다.

city.json 스키마에 대한 참조가 포함된 growing.json 스키마

{
 "$id": "https://example.com/citizen.schema.json",
 "$schema": "http://json-schema.org/draft-07/schema#",
 "title": "Citizen",
 "type": "object",
 "properties": {
   "firstName": {
     "type": "string",
     "description": "The citizen's first name."
   },
   "lastName": {
     "type": "string",
     "description": "The citizen's last name."
   },
   "age": {
     "description": "Age in years which must be equal to or greater than zero.",
     "type": "integer",
     "minimum": 0
   },
   "city": {
     "$ref": "city.json"
   }
 }
}

city.json schema

{
 "$id": "https://example.com/city.schema.json",
 "$schema": "http://json-schema.org/draft-07/schema#",
 "title": "City",
 "type": "object",
 "properties": {
   "name": {
     "type": "string",
     "description": "The city's name."
   },
   "zipCode": {
     "type": "integer",
     "description": "The zip code.",
     "minimum": 0
   }
 }
}

Protobuf serializer 구성

다음과 같이 Protobuf serializer 클래스를 구성할 수 있습니다.

Protobuf deserializer 구성

serializer의 다음 구성 설정과 일치하도록 Protobuf deserializer 클래스를 구성해야 합니다.

protobuf SerDes 및 아티팩트 참조

가져오기 문과 함께 복잡한 Protobuf 메시지를 사용하면 가져온 Protobuf 메시지가 서비스 레지스트리에 별도의 아티팩트로 저장됩니다. 그러면 서비스 레지스트리에서 Protobuf 메시지를 확인하기 위해 기본 스키마를 가져오면 참조된 체계도 검색되므로 전체 메시지 스키마를 확인하고 직렬화할 수 있습니다.

가져온 .mode.proto 파일인 table_info.proto 파일

syntax = "proto3";
package sample;
option java_package = "io.api.sample";
option java_multiple_files = true;

import "sample/mode.proto";

message TableInfo {

 int32 winIndex = 1;
 Mode mode = 2;
 int32 min = 3;
 int32 max = 4;
 string id = 5;
 string dataAdapter = 6;
 string schema = 7;
 string selector = 8;
 string subscription_id = 9;
}

mode.proto 파일

syntax = "proto3";
package sample;
option java_package = "io.api.sample";
option java_multiple_files = true;

enum Mode {

MODE_UNKNOWN = 0;
RAW = 1;
MERGE = 2;
DISTINCT = 3;
COMMAND = 4;
}